天天看點

window 上測試 kafka

一、下載下傳 kafka_2.10-0.10.1.1.tgz;注意下載下傳二進制版本

window 上測試 kafka

二、啟動zookeeper(視窗1);指令:bin\windows\zookeeper-server-start.bat   config\zookeeper.properties

window 上測試 kafka

三、啟動zookeeper(視窗2);測試指令:zookeeper-shell.bat localhost:2181

window 上測試 kafka

四、啟動kafka(視窗3);指令:bin\windows\kafka-server-start.bat config\server.properties

window 上測試 kafka

五、建立topic(視窗4);指令:bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 3 --topic mytopic

window 上測試 kafka

六、檢視topic(視窗4);指令:kafka-topics.bat --describe --zookeeper localhost:2181 --topic mytopic

window 上測試 kafka

七、釋出/生産消息視窗(視窗5);指令:kafka-console-producer.bat --broker-list localhost:9092 --topic mytopic

window 上測試 kafka

八、消費消息視窗(視窗5);指令:kafka-console-consumer.bat --zookeeper localhost:2181 --from-beginning --topic mytopic

window 上測試 kafka

九、producer視窗輸入,可以在consumer視窗輸出

十、問題:在啟動zookeeper時,出現:指令文法不正确, 找不到或無法加載主類   Files\Java\jdk1.8.0_51\lib; C:\Program: 的錯誤。

原因:因為是windows上檔案夾存在空格導緻啟動zookeeper失敗,即是JAVA_HOME的環境變量中存在空格(C:\Program Files\Java\jdk1.8.0_51)導緻。

解決辦法:修改Java的環境變量路徑,使其路徑中不存在空格。