1 基礎環境
win10,jdk1.8
2 kafka_2.11-0.10.1.1 下載kafka，並解壓縮到指定目錄,例如C:/kafka
3 更改啟動檔案
3.1將bin\windows下的bat檔案移動到bin資料夾下，並刪除無用的.sh檔案
3.2 修改 zookeeper-server-start.bat、 kafka-server-start.bat、kafka-run-class.bat檔案

%~dp0../../#更改為%~dp0../
#例如
....
SetLocal
IF ["%KAFKA_LOG4J_OPTS%"] EQU [""] (
    set KAFKA_LOG4J_OPTS=-Dlog4j.configuration=file:%~dp0../config/log4j.properties
)
IF ["%KAFKA_HEAP_OPTS%"] EQU [""] (
....
 

3.3 修改kafka-run-class.bat 啟動指令碼，如果java在C:/Program Files/路徑下(或者其他路徑還空格的)

...
set JAVA="%JAVA_HOME%/bin/java"
...
set COMMAND=%JAVA% %KAFKA_HEAP_OPTS% %KAFKA_JVM_PERFORMANCE_OPTS% %KAFKA_JMX_OPTS% %KAFKA_LOG4J_OPTS% -cp "%CLASSPATH%" %KAFKA_OPTS% %* #%CLASSPATH% 加""
...

3.4 修改啟動配置檔案對日誌路徑的配置
server.properties

...
log.dirs=d:/resp/kafka/tmp/kafka-logs 
...

zookeeper.properties

dataDir=d:/resp/kafka/tmp/zookeepers

4 啟動kafka

#4.1 啟動zookeeper
    zookeeper-server-start.bat ..\config\zookeeper.properties
#4.2 啟動kafka sever,預設埠是9092
    kafka-server-start.bat ..\config\server.properties

5 簡單使用

#5.1 建立topic
kafka
 
-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 3 --topic my-test-topic
#檢視topic
kafka-topics.bat --describe --zookeeper localhost:2181 --topic my-test-topic
#5.2 console produre message after enter key
kafka-console-producer.bat --broker-list localhost:9092 --topic my-test-topic
#5.2 console consumer message
kafka-console-consumer.bat --zookeeper localhost:2181 --from-beginning --topic my-test-topic