啟動(dòng)服務(wù)
- 安裝配置好zookeeper揣炕，添加好環(huán)境變量苞笨，打開cmd族阅，輸入命令啟動(dòng)服務(wù)篓跛。
zkServer
- 在%KAFKA_HOME%目錄，按shift+鼠標(biāo)右鍵坦刀，選擇“在此處打開命令窗口”愧沟，在控制臺(tái)輸入命令啟動(dòng)服務(wù)。
.\bin\windows\kafka-server-start.bat .\config\server.properties
kafka命令
- 創(chuàng)建主題
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic 主題名
- 查看主題
.\bin\windows\kafka-topics.bat --zookeeper localhost:2181 --list
- 啟動(dòng)生產(chǎn)者producer：
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic 主題名
- 從文件中向主題批量發(fā)送數(shù)據(jù)：
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic 主題名 < 文件名
- 啟動(dòng)消費(fèi)者consumer
.\bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic 主題名
