安裝kafka需要提前安裝Zookeeper
一、Zookeeper安裝
1.? 下載安裝包 https://zookeeper.apache.org/releases.html 注意：要下載帶bin的安裝包
2.? 解壓并進(jìn)入ZooKeeper目錄，如：D:\onworking\apache-zookeeper-3.7.0-bin，新建data目錄
3.? 進(jìn)入conf目錄，復(fù)制一份zoo_sample.cfg重命名為zoo.cfg
4.? 編輯zoo.cfg，dataDir=D:\\onworking\\apache-zookeeper-3.7.0-bin\\data
5.? 進(jìn)入bin目錄，雙擊zkServer.cmd運(yùn)行Zookeeper
6.? 出現(xiàn)如下截圖則Zookeeper啟動成功
二、?Kafka安裝
1.? 下載安裝包 https://kafka.apache.org/downloads
2.? 解壓并進(jìn)入Kafka目錄，如：D:\onworking\kafka_2.13-3.1.0，新建kafka-logs目錄
3.? 進(jìn)入config目錄，編輯server.properties文件log.dirs=D:\\onworking\\kafka_2.13-3.1.0\\kafka-logs
4.? 在D:\onworking\kafka_2.13-3.1.0目錄下打開cmd窗口，輸入命令.\bin\windows\kafka-server-start.bat .\config\server.properties
5.? 出現(xiàn)如下截圖則Kafka啟動成功?
三、Windows下 Kafka常用命令?-topic的增刪改查
進(jìn)入kafka目錄下，不用進(jìn)入bin目錄下
-- 查看所有topic
.\bin\windows\kafka-topics.bat --zookeeper localhost:2181 --list
-- 查看指定topic信息
.\bin\windows\kafka-topics.bat --zookeeper localhost:2181 --describe --topic <主題名稱>
-- 創(chuàng)建topic信息
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic <主題名稱>
-- 創(chuàng)建生產(chǎn)者產(chǎn)生消息，不關(guān)閉頁面
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic <主題名稱>
-- 創(chuàng)建消費(fèi)者接收消息，不關(guān)閉頁面
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic <主題名稱> --from-beginning
-- 刪除topic：
.\bin\windows\kafka-topics.bat kafka.admin.DeleteTopicCommand --zookeeper localhost:2181 --delete --topic <主題名稱>
四、Windows下查看消費(fèi)情況
--查詢所有消費(fèi)者組
.\bin\windows\kafka-consumer-groups.bat --bootstrap-server localhost:9092 --list
--查詢對應(yīng)組的消費(fèi)情況
.\bin\windows\kafka-consumer-groups.bat --bootstrap-server localhost:9092 --group <上一步查詢出來的組的名稱> --describe
---------------------------------------------------------------
ps:當(dāng)啟動Zookeeper或Kafka報(bào)文件夾錯誤時
1.清理zookeeper的dataDir目錄里面的內(nèi)容，zoo.cfg里面的指定的dataDir目錄（數(shù)據(jù)請?zhí)崆皞浞?
2.清理kafka文件夾下kafka_logs和logs目錄里面的內(nèi)容（數(shù)據(jù)請?zhí)崆皞浞?
