当前位置:  开发笔记 > 编程语言 > 正文

Kafka bootstrap-servers与kafka-console-consumer中的zookeeper

如何解决《Kafkabootstrap-servers与kafka-console-consumer中的zookeeper》经验,为你挑选了1个好方法。

我正在尝试使用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编译.



1> nico..:

我不知道出了什么问题.可能我把Kafka或Zookeeper置于一种奇怪的状态.删除log.dir每个代理中的主题和zookeeper主题/brokers/topics然后重新创建主题后,Kafka消费者的行为与预期一致.

推荐阅读
雯颜哥_135
这个屌丝很懒,什么也没留下!
DevBox开发工具箱 | 专业的在线开发工具网站    京公网安备 11010802040832号  |  京ICP备19059560号-6
Copyright © 1998 - 2020 DevBox.CN. All Rights Reserved devBox.cn 开发工具箱 版权所有