qyf_5445
quyf
采纳率0%
2019-08-10 22:07 阅读 2.8k

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

今天试了两个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 这种也能消费到消息

  • 点赞
  • 写回答
  • 关注问题
  • 收藏
  • 复制链接分享

3条回答 默认 最新

  • zytbft 专注大数据开发 2020-08-19 15:06

    遇到了同样的问题:kafka消费者 --zookeeper可以消费到消息,但是--bootstrap-server不行。我的zookeeper版本 是3.4.10,kafka版本是kafka_2.11-0.11.0.0。
    命令如下:

    kafka-console-consumer.sh --bootstrap-server qf03:9092 --topic test --from-beginning

    解决方案:

    我重新安装了kafka集群,删除了zookeeper里面的kafka内容。然后就好了

    kafka-topics.sh --create --topic test --replication-factor 1 --partitions 3 --zookeeper qf01:2181

    点赞 1 评论 复制链接分享
  • qq_40135705 长孙歌澜 2019-09-05 19:54

    我也遇到了这个问题,搞了半天,首先--zookeeper会从zookeeper获取消息,--bootstrap-server会从kafka的所有分片节点获取消息。而我出现这个问题的原因是:添加了--from-beginning从头开始,而有的节点没有启动(我模拟宕机leader把它挂掉了),获取以前的所有消息的时候因为这个节点上还有消息,但是获取不到;如果是--zookeeper的话会从zookeeper获取以前的消息,就会成功。所以去掉--from-beginning就好了。我的错误是这样,希望能够帮助后面百度到这个问题的人

    点赞 评论 复制链接分享
  • qq_43622126 宇文虚中- 2020-04-17 22:36

    去掉--from-beginning我也消费不了

    点赞 评论 复制链接分享

相关推荐