我正在尝试使用3个代理和zookeeper来测试运行单个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编译.
我不知道出了什么问题.可能我把Kafka或Zookeeper置于一种奇怪的状态.删除log.dir
每个代理中的主题和zookeeper主题/brokers/topics
然后重新创建主题后,Kafka消费者的行为与预期一致.