卡夫卡消費者查詢

Question

要啓動卡夫卡消費者，我必須使用以下參數運行它。

卡夫卡控制檯consumer.bat --zookeeper本地主機：2181 --topic MyTopic

想知道爲什麼它需要有一個動物園管理員爲PARAM，如果我使用代理PARAM將它不起作用類似於生產者是如何啓動的。消費者需要注意經紀人/集羣而不是動物園管理員的位置。

\卡夫卡控制檯producer.bat --broker --list本地主機：9092 --topic MyTopic

這是Windows，我不知道如何它在Unix操作系統。

-Chandra

Answer 1

您正在調用舊的Kafka Consumer。老消費者需要動物園管理員協調從哪個經紀人獲取數據。

新消費者不需要zookeeper參數。

.\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic MyTopic --new-consumer 

或者，您可以添加--from-beginning參數來讀取主題中的舊記錄。