一、安裝方法
前提 ： 本地安裝zookeeper
2、解壓檔案，進入目錄，建立 logs資料夾。
進入config目錄，開啟 server.properties 檔案：
注釋#log.dirs=/tmp/kafka-logs
#zookeeper.connect=localhost:2181
新增配置
log.dirs=e:\programfiles\kafka_2.13-2.5.1\logs
zookeeper.connect=127.0.0.1:2181
3、啟動 zookeeper
4、啟動kafka
win+r 輸入cmd 進入命令列視窗。
進入kafka目錄 e:\programfiles\kafka_2.13-2.5.1
輸入 .\bin\windows\kafka-server-start.bat .\config\server.properties
二、執行kafka命令
1、建立主題
命令列進入目錄
c:\users\administrator>e:
e:>cd e:\programfiles\kafka_2.13-2.5.1\bin\windows
建立主題
e:\programfiles\kafka_2.13-2.5.1\bin\windows>kafka-topics.bat --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic test
created topic test.
2、建立生產者訊息
e:\programfiles\kafka_2.13-2.5.1\bin\windows>kafka-console-producer.bat --broker-list 127.0.0.1:9092 --topic test
3、消費者獲取訊息
e:\programfiles\kafka_2.13-2.5.1\bin\windows>kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
kafka-console-consumer.bat –zookeeper localhost:2181 –topic test
檢視所有主題
e:\programfiles\kafka_2.13-2.5.1\bin\windows>kafka-topics.bat -list -zookeeper localhost:2181
windows下 kafka啟動報錯：另乙個程式正在使用此檔案，程序無法訪問
kafka在windows平台就是有這個bug，沒辦法。只能手動刪除\kafka_2.12-2.5.0kafka-logs裡的日誌檔案重啟kafka
文件參考
kafka本地除錯
主要本地除錯命令 nohup bin kafka server start.sh config server.properties bin kafka server stop.sh bin kafka topics.sh create zookeeper localhost 2181 replica...
kafka本地部署
zookeeper安裝 zookeeper安裝位址 kafka安裝 kafka安裝位址 版本對應關係 kafka zookeeper kafka 2.12 2.4.0 apache zookeeper 3.6.0 bin zookeeper和kafka的版本不對應好像是會出問題 使用zookeepe...
ELK 本地搭建kafka環境
tar zxvf kafka 2.11 2.0.1.tgz kafka需要安裝zookee使用，但kafka整合zookeeper,在單機搭建時可直接使用。使用需配置kafka 2.11 1.1.0 config 下的 zookeeper.properties 配置 zookeeper.proper...