kafka_2.11-1.0.0在控制台kafka-console-consumer消费者消费的时候zookeeper 和 bootstrap-server区别

发布于 2022-01-02 07:59:57 字数 1391 浏览 405 评论 1

今天试了两个kafka的版本都存在这个问题

1、创建一个topic

kafka-topics.bat --create --partitions 1 --replication-factor 1 --topic test --zookeepe
r localhost:2181

2、对改topic进行消息写入

kafka-console-producer.bat --broker-list localhost:9092 --topic test

3,控制台形式消费该topic消息,--zookeeper localhost:2181 这种能正常消费消息

kafka-console-consumer.bat --zookeeper localhost:2181 --topic test --from-beginning

4,同样是控制台消费,--bootstrap-server localhost:9092,这样就收不到消费消息

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginn
ing

5,今天在windows 和 虚拟机linux环境下 都存在这个问题,而且也试了两个kafka版本

6,stackoverflow也看到有人出现这个问题

https://stackoverflow.com/questions/41774446/kafka-bootstrap-servers-vs-zookeeper-in-kafka-console-consumer

有无人遇到一样的问题,怎么让 --bootstrap-server localhost:9092 这种也能消费到消息

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

半世蒼涼 2022-01-06 02:41:00

解决了,还是配置不规范引起的,listeners=PLAINTEXT://:9092 不要这样默认,

最好配置一下listeners=PLAINTEXT://hostname:9092

# The address the socket server listens on. It will get the value returned from 
# java.net.InetAddress.getCanonicalHostName() if not configured.
#   FORMAT:
#     listeners = listener_name://host_name:port
#   EXAMPLE:
#     listeners = PLAINTEXT://your.host.name:9092
#listeners=PLAINTEXT://:9092

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文