北京知名网站,logo123设计网,网站 什么语言开发,潍坊建设企业网站压缩包下载地址#xff1a;https://www.apache.org/dyn/closer.cgi?path/kafka/3.6.1/kafka_2.13-3.6.1.tgz
启动kafka步骤
zookeeper-server-start.bat
rem 闭命令提示符窗口的命令回显#xff0c;这样在运行脚本时不会显示脚本的具体命令内容
echo offrem 命令行启动未…压缩包下载地址https://www.apache.org/dyn/closer.cgi?path/kafka/3.6.1/kafka_2.13-3.6.1.tgz
启动kafka步骤
zookeeper-server-start.bat
rem 闭命令提示符窗口的命令回显这样在运行脚本时不会显示脚本的具体命令内容
echo offrem 命令行启动未提供参数则输出: USAGE:命令 zookeeper.properties 中止
IF [%1] EQU [] (echo USAGE: %0 zookeeper.propertiesEXIT /B 1
)
rem 开始了一个局部环境只在当前脚本执行过程中有效
SetLocal
rem 未设置值则设置
IF [%KAFKA_LOG4J_OPTS%] EQU [] (set KAFKA_LOG4J_OPTS-Dlog4j.configurationfile:%~dp0../../config/log4j.properties
)
IF [%KAFKA_HEAP_OPTS%] EQU [] (set KAFKA_HEAP_OPTS-Xmx512M -Xms512M
)
rem %~dp0获取命令的文件路径%* 读取执行这个命令携带的锁有参数
%~dp0kafka-run-class.bat org.apache.zookeeper.server.quorum.QuorumPeerMain %*rem 在脚本中限定变量的作用范围以防止对环境变量的更改影响到脚本之外的其他部分
EndLocal
kafka-run-class.bat
echo offsetlocal enabledelayedexpansionIF [%1] EQU [] (echo USAGE: %0 classname [opts]EXIT /B 1
)rem Using pushd popd to set BASE_DIR to the absolute path
rem pushd表示切换目录,这里作用是切换到%~dp0对应的上2级目录
pushd %~dp0..\..
rem CD是系统变量,%CD%表示当前工作目录的路径
set BASE_DIR%CD%
rem popd 切回原来的目录
popdIF [%SCALA_VERSION%] EQU [] (set SCALA_VERSION2.13.11
)rem 延迟环境变量扩展后的一种变量访问方式!var!
IF [%SCALA_BINARY_VERSION%] EQU [] (for /f tokens1,2 delims. %%a in (%SCALA_VERSION%) do (set FIRST%%aset SECOND%%bif [!SECOND!] EQU [] (set SCALA_BINARY_VERSION!FIRST!) else (set SCALA_BINARY_VERSION!FIRST!.!SECOND!))
)rem Classpath addition for kafka-core dependencies 为kafka核心依赖添加类路径
rem for %%i in (...) do (...)这是一个 for 循环用于遍历指定路径下满足特定条件的文件
for %%i in (%BASE_DIR%\core\build\dependant-libs-%SCALA_VERSION%\*.jar) do (rem call :concat %%i
)rem Classpath addition for kafka-examples
for %%i in (%BASE_DIR%\examples\build\libs\kafka-examples*.jar) do (call :concat %%i
)rem Classpath addition for kafka-clients
for %%i in (%BASE_DIR%\clients\build\libs\kafka-clients*.jar) do (call :concat %%i
)rem Classpath addition for kafka-streams
for %%i in (%BASE_DIR%\streams\build\libs\kafka-streams*.jar) do (call :concat %%i
)rem Classpath addition for kafka-streams-examples
for %%i in (%BASE_DIR%\streams\examples\build\libs\kafka-streams-examples*.jar) do (call :concat %%i
)for %%i in (%BASE_DIR%\streams\build\dependant-libs-%SCALA_VERSION%\rocksdb*.jar) do (call :concat %%i
)rem Classpath addition for kafka tools 为kafka工具添加类路径
for %%i in (%BASE_DIR%\tools\build\libs\kafka-tools*.jar) do (call :concat %%i
)for %%i in (%BASE_DIR%\tools\build\dependant-libs-%SCALA_VERSION%\*.jar) do (call :concat %%i
)
rem 两层for循环
for %%p in (api runtime file json tools) do (for %%i in (%BASE_DIR%\connect\%%p\build\libs\connect-%%p*.jar) do (call :concat %%i)if exist %BASE_DIR%\connect\%%p\build\dependant-libs\* (call :concat %BASE_DIR%\connect\%%p\build\dependant-libs\*)
)rem Classpath addition for release
for %%i in (%BASE_DIR%\libs\*) do (call :concat %%i
)rem Classpath addition for core
for %%i in (%BASE_DIR%\core\build\libs\kafka_%SCALA_BINARY_VERSION%*.jar) do (call :concat %%i
)rem JMX settings JMX的设置
IF [%KAFKA_JMX_OPTS%] EQU [] (set KAFKA_JMX_OPTS-Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.authenticatefalse -Dcom.sun.management.jmxremote.sslfalse
)rem JMX port to use 使用的JMX端口
IF [%JMX_PORT%] NEQ [] (set KAFKA_JMX_OPTS%KAFKA_JMX_OPTS% -Dcom.sun.management.jmxremote.port%JMX_PORT%
)rem Log directory to use 要使用的日志目录
IF [%LOG_DIR%] EQU [] (set LOG_DIR%BASE_DIR%/logs
)rem Log4j settings
IF [%KAFKA_LOG4J_OPTS%] EQU [] (set KAFKA_LOG4J_OPTS-Dlog4j.configurationfile:%BASE_DIR%/config/tools-log4j.properties
) ELSE (rem create logs directory 创建一个目录文件夹IF not exist %LOG_DIR% (mkdir %LOG_DIR%)
)set KAFKA_LOG4J_OPTS-Dkafka.logs.dir%LOG_DIR% %KAFKA_LOG4J_OPTS%rem Generic jvm settings you want to add 要添加的通用jvm设置
IF [%KAFKA_OPTS%] EQU [] (set KAFKA_OPTS
)set DEFAULT_JAVA_DEBUG_PORT5005
set DEFAULT_DEBUG_SUSPEND_FLAGn
rem Set Debug options if enabled
IF [%KAFKA_DEBUG%] NEQ [] (IF [%JAVA_DEBUG_PORT%] EQU [] (set JAVA_DEBUG_PORT%DEFAULT_JAVA_DEBUG_PORT%)IF [%DEBUG_SUSPEND_FLAG%] EQU [] (set DEBUG_SUSPEND_FLAG%DEFAULT_DEBUG_SUSPEND_FLAG%)set DEFAULT_JAVA_DEBUG_OPTS-agentlib:jdwptransportdt_socket,servery,suspend!DEBUG_SUSPEND_FLAG!,address!JAVA_DEBUG_PORT!IF [%JAVA_DEBUG_OPTS%] EQU [] (set JAVA_DEBUG_OPTS!DEFAULT_JAVA_DEBUG_OPTS!)echo Enabling Java debug options: !JAVA_DEBUG_OPTS!set KAFKA_OPTS!JAVA_DEBUG_OPTS! !KAFKA_OPTS!
)rem Which java to use
IF [%JAVA_HOME%] EQU [] (set JAVAjava
) ELSE (set JAVA%JAVA_HOME%/bin/java
)rem Memory options
IF [%KAFKA_HEAP_OPTS%] EQU [] (set KAFKA_HEAP_OPTS-Xmx256M
)rem JVM performance options
IF [%KAFKA_JVM_PERFORMANCE_OPTS%] EQU [] (set KAFKA_JVM_PERFORMANCE_OPTS-server -XX:UseG1GC -XX:MaxGCPauseMillis20 -XX:InitiatingHeapOccupancyPercent35 -XX:ExplicitGCInvokesConcurrent -Djava.awt.headlesstrue
)IF not defined CLASSPATH (echo Classpath is empty. Please build the project first e.g. by running gradlew jarAllEXIT /B 2
)
rem %?% 读取环境变量
set COMMAND%JAVA% %KAFKA_HEAP_OPTS% %KAFKA_JVM_PERFORMANCE_OPTS% %KAFKA_JMX_OPTS% %KAFKA_LOG4J_OPTS% -cp %CLASSPATH% %KAFKA_OPTS% %*
rem echo.
rem echo %COMMAND%
rem echo.
%COMMAND%rem 将控制权转移到脚本的文件尾
goto :eof
:concat
rem 这是一个条件语句用于检查CLASSPATH环境变量是否已定义
IF not defined CLASSPATH (set CLASSPATH%~1
) ELSE (set CLASSPATH%CLASSPATH%;%~1
)
启动失败日志
缺少启动参数 输入行太长
组合起来的执行命令太长Windows系统不支持。将项目放到盘符目录下。
找不到类
为了解决路径太长去掉了一级目录。因为启动命令中有通过当前命令的位置去加载jar包。
绝对路径配置文件加载报错
# 文件地址错误
/kafka_2.13-3.6.1/bin/windows/zookeeper-server-start.bat /kafka_2.13-3.6.1/config/zookeeper.properties 先对路径无法启动
./bin/windows/zookeeper-server-start.bat ./bin/windows/zookeeper.properties/bin/windows/zookeeper-server-start.bat /bin/windows/zookeeper.propertiesbin/windows/zookeeper-server-start.bat bin/windows/zookeeper.properties 启动成功
1. 启动zookeeper
# 当前路径下启动
zookeeper-server-start.bat ../../config/zookeeper.properties# 将文件复制一份到启动命令处
zookeeper-server-start.bat zookeeper.properties# 绝对路径启动
/kafka_2.13-3.6.1/bin/windows/zookeeper-server-start.bat /kafka_2.13-3.6.1/bin/windows/zookeeper.properties/kafka_2.13-3.6.1/bin/windows/zookeeper-server-start.bat /kafka_2.13-3.6.1/config/zookeeper.properties# Window使用相对路径 系统找不到指定的路径
/bin/windows/zookeeper-server-start.bat /bin/config/zookeeper.properties/kafka_2.13-3.6.1/bin/windows/zookeeper-server-start.bat /kafka_2.13-3.6.1/bin/config/zookeeper.properties# 相对路径启动
call ./bin/windows/zookeeper-server-start.bat ./config/zookeeper.propertiescall ./bin/windows/zookeeper-server-start.bat ./bin/windows/zookeeper.properties ctrl C停止或者关闭窗口
3.启动kafka-server
# 当前路径下启动 将文件复制一份到启动命令处
kafka-server-start.sh config/server.properties# 其他方式启动同上
