zookeeper-3.4.10
https://www.apache.org/dyn/closer.cgi/zookeeper/
kafka_2.11-1.0.0
http://kafka.apache.org/downloads
解壓zookeeper到D盤根目錄蔫磨,進入conf目錄拯杠,拷貝zoo_sample.cfg文件文件并重命名為zoo.cfg。
打開zoo.cfg文件,”dataDir=/tmp/zookeeper”是Linux系統(tǒng)下的路徑配置扔傅,windows環(huán)境下修改為”dataDir=D:\zookeeper-3.4.10\data”苹支。
進入bin文件夾
zookeeper 啟動完成
解壓kafka到D盤根目錄寞焙,進入config文件打開 server.properties文件锅移,修改
log.dirs=D:\kafka_2.11-1.0.0\kafka-logs
zookeeper.connect=localhost:2181
kafka會按照默認,在9092端口上運行纺荧,連接zookeeper的默認端口:2181
進入D:\kafka_2.11-1.0.0旭愧,按下Shift+右鍵,選擇“打開命令窗口”選項宙暇,打開命令行输枯,輸入
.\bin\windows\kafka-server-start.bat .\config\server.properties
注意:啟用kafka前請確保zooKeeper實例已經(jīng)準備好并開始運行(不要關閉這個命令窗口)
測試kafka
創(chuàng)建主題,進入D:\kafka_2.11-1.0.0占贫,按下Shift+右鍵桃熄,選擇“打開命令窗口”選項,打開命令行型奥,輸入
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
注意:不要關閉窗口
查看主題瞳收,進入D:\kafka_2.11-1.0.0碉京,按下Shift+右鍵,選擇“打開命令窗口”選項螟深,打開命令行谐宙,輸入
.\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
注意:不要關閉窗口
創(chuàng)建生產(chǎn)者,進入D:\kafka_2.11-1.0.0界弧,按下Shift+右鍵凡蜻,選擇“打開命令窗口”選項,打開命令行垢箕,輸入
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
注意:不要關閉窗口
創(chuàng)建消費者咽瓷,進入D:\kafka_2.11-1.0.0,按下Shift+右鍵舰讹,選擇“打開命令窗口”選項,打開命令行闪朱,輸入
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning