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