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

quyf 发布于 08/10 22:01
阅读 202
收藏 0

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

加载中
0
quyf
quyf

解决了,还是配置不规范引起的,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

返回顶部
顶部