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

Question

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

Answer 1

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