卡夫卡消费者查询

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参数来读取主题中的旧记录。