要启动Kafka消费者，我必须使用以下参数运行它 .
kafka-console-consumer.bat --zookeeper localhost:2181 --topic MyTopic
想知道为什么它需要一个动物园管理员作为一个参数，如果我使用经纪人参数将不会像 生产环境 者的推出方式那样工作 . 消费者需要了解代理/集群而不是zookeeper位置 .
.\kafka-console-producer.bat --broker --list localhost:9092 --topic MyTopic
这是在Windows上，我不确定它在Unix风格如何 .
-Chandra
1 回答
你正在调用旧的Kafka Consumer . 旧的消费者要求zookeeper协调从哪个代理获取数据 .
新的使用者不需要zookeeper参数 .
（可选）您可以添加
--from-beginning参数以读取主题中的旧记录 .