windows下使用kafka的常用命令

參考文檔：

https://blog.csdn.net/evankaka/article/details/52421314

http://orchome.com/6

1 啟動zookeeper

cmd進入zookeeper的bin目錄，輸入zkServer.cmd

2 啟動kafka

cmd進入kafka的安裝目錄

.\bin\windows\kafka-server-start.bat .\config\server.properties

創建主題，

1.進入Kafka安裝目錄D:\kafka_2.11-1.1.0
2.按下Shift+右鍵，選擇“打開命令窗口”選項，打開命令行。
3.現在輸入

只有一個分區和一個備份：

.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

創建好之后，可以通過運行以下命令，查看已創建的topic信息：(查看的是所有的主題)

.\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

查看指定主題的詳細信息：

.\bin\windows\kafka-topics.bat --describe --zookeeper localhost:2181 --topic test

 

通過describe與under-replicated-partitions命令組合使用，可以查看處於“under-replicated（復制）”狀態的分區。處於該狀態的主題可能正在進行同步操作

.\bin\windows\kafka-topics.bat --describe --zookeeper localhost:2181 --under-replicated-partitions

刪除主題：

1 在server.properties下面增加：

delete.topic.enable=true

.\bin\windows\kafka-topics.bat --delete --zookeeper localhost:2181 --topic test

注意不要關了這個窗口！

（2）創建生產者

1.進入Kafka安裝目錄D:\kafka_2.11-1.1.0
2.按下Shift+右鍵，選擇“打開命令窗口”選項，打開命令行。
3.現在輸入

.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test

 

創建消費者

1.進入Kafka安裝目錄D:\kafka_2.11-1.1.0
2.按下Shift+右鍵，選擇“打開命令窗口”選項，打開命令行。
3.現在輸入

.\bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic test

測試：

 

 
消費者可以同過whitelist訂閱多個主題：

.\bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --whitelist "test1|test2"