啟動kafka之前先要啟動zookeeper,而kafka里面時自帶有zookeeper的,建議獨立部署一套zookeeper服務,kafka下的zookeeper啟動命令:
zookeeper-server-start.bat ..\..\config\zookeeper.properties
啟動kafka 服務的命令:
kafka-server-start.bat ..\..\config\server.properties
如果執行該命令報如下錯誤:
錯誤: 找不到或無法加載主類 Files\Java\jdk1.7.0_80\lib;C:\Program.....
解決方式如下:在kafka安裝目錄中找到bin\windows目錄中的kafka-run-class.bat找到142行為%CLASSPATH%加上雙引號 修改前: set COMMAND=%JAVA% %KAFKA_HEAP_OPTS% %KAFKA_JVM_PERFORMANCE_OPTS% %KAFKA_JMX_OPTS% %KAFKA_LOG4J_OPTS% -cp %CLASSPATH% %KAFKA_OPTS% %* 修改后: set COMMAND=%JAVA% %KAFKA_HEAP_OPTS% %KAFKA_JVM_PERFORMANCE_OPTS% %KAFKA_JMX_OPTS% %KAFKA_LOG4J_OPTS% -cp "%CLASSPATH%" %KAFKA_OPTS% %*
建立系統環境變量,本地可以快捷啟動命令:
首先在電腦屬性->高級系統設置->環境變量->系統變量中加入kafka的bin\windows路徑,如本人加的是:E:\MQ\kafka_2.12-2.1.0\bin\windows
在啟動了獨立zookeeper情況下,執行如下命令:
kafka-server-start.bat E:\MQ\kafka_2.12-2.1.0\config\server.properties
上面的方式還是不夠方便,可以直接將以下命令寫成一個.bat格式的腳本就可以雙擊快速執行了。
kafka-server-start.bat E:\MQ\kafka_2.12-2.1.0\config\server.properties pause