創建消費者時候報錯:
D:\kafka_2.12-2.3.0\bin\windows>kafka-console-consumer.bat --zookeeper localhost:2181 --topic test zookeeper is not a recognized option
問題原因:
新版本kafka中,--zookeeper這種啟動方式已刪除。
解決辦法:
0.90版本之后啟動消費者的方法如下:
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
