zookeeper is not a recognized option

創建消費者時候報錯：

.\bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic ads_log 
zookeeper is not a recognized option

問題原因：

新版本kafka中，--zookeeper這種啟動方式已刪除。

解決辦法：

0.90版本之后啟動消費者的方法如下：

.\bin\windows\kafka-topics.bat  --bootstrap-server localhost:9092 --topic ads_log --from-beginning

 

 --bootstrap-server 參數

 創建主題：都可以

.\bin\windows\kafka-topics.bat --create  --bootstrap-server localhost:9092 --replication-factor 1 --partitions 3 --topic ads

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

 

完結！