apache-kafka - Kafka bootstrap-servers vs zookeeper in kafka-console-consumer

Question

我正在尝试使用 3 个代理和动物园管理员测试运行单个 Kafka 节点。我希望使用控制台工具进行测试。我这样运行生产者:

kafka-console-producer --broker-list localhost:9092,localhost:9093,localhost:9094 --topic testTopic

然后我像这样运行消费者:

kafka-console-consumer --zookeeper localhost:2181 --topic testTopic --from-beginning

我可以在生产者中输入消息并在消费者中看到它们，正如预期的那样。 然而 ，当我使用 bootstrap-server 运行更新版本的消费者时，我什么也得不到。例如

kafka-console-consumer --bootstrap-server localhost:9092,localhost:9093,localhost:9094 --topic testTopic --from-beginning

当我在端口 9092 上运行一个代理时，这很好用，所以我完全困惑。有没有办法可以看到zookeeper提供的引导服务器？引导服务器与代理列表不同吗？ Kafka 用 Scala 2.11 编译。

Answer 1

我不知道出了什么问题。可能我把 Kafka 或 Zookeeper 置于一种奇怪的状态。删除 log.dir 中的主题后/brokers/topics 中的每个经纪人和动物园管理员主题然后重新创建主题，Kafka 消费者的行为符合预期。