我在使用bootstrap-server(即Kafka服务器)消费消息时遇到问题 . 知道为什么没有zookeeper就无法使用消息?
-
Kafka版本:kafka_2.11-1.0.0
-
Zookeeper版本:kafka_2.11-1.0.0
-
Zookeeper主机和端口:zkp02.mp.com:2181
-
Kafka主持人和港口:kfk03.mp.com:9092
制作一些消息:
[kfk03.mp.com ~]$ /bnsf/kafka/bin/kafka-console-producer.sh --broker-list kfk03.mp.com:9092 --topic test
>hi
>hi
如果我给 –-bootstrap-server
消费者,消费者无法消费消息:
[kfk03.mp.com ~]$
/bnsf/kafka/bin/kafka-console-consumer.sh --bootstrap-server kfk03.mp.com:9092 --topic test --from-beginning
消费者在给出 --zookeeper
服务器而不是 --bootstrap-server
时能够使用消息 - :
[kfk03.mp.com ~]$ /bnsf/kafka/bin/kafka-console-consumer.sh --zookeeper zkp02.mp.com:2181 --topic test --from-beginning
Using the ConsoleConsumer with old consumer is deprecated and will be removed in a future major release. Consider using the new consumer by passing [bootstrap-server] instead of [zookeeper].
{"properties": {"messageType": "test", "sentDateTime": "2018-02-25T21:46:00.000+0000"}, "name": "Uttam Anand", "age": 29}
{"properties": {"messageType": "test", "sentDateTime": "2018-02-25T21:46:00.000+0000"}, "name": "Uttam Anand", "age": 29}
{"properties": {"messageType": "test", "sentDateTime": "2018-02-25T21:46:00.000+0000"}, "name": "Uttam Anand", "age": 29}
hi
{"properties": {"messageType": "test", "sentDateTime": "2018-02-25T21:46:00.000+0000"}, "name": "Uttam Anand", "age": 29}
{"properties": {"messageType": "test", "sentDateTime": "2018-02-25T21:46:00.000+0000"}, "name": "Uttam Anand", "age": 29}
{"properties": {"messageType": "test", "sentDateTime": "2018-02-25T21:46:00.000+0000"}, "name": "Uttam Anand", "age": 29}
{"properties": {"messageType": "test", "sentDateTime": "2018-02-25T21:46:00.000+0000"}, "name": "Uttam Anand", "age": 29}
{"properties": {"messageType": "test", "sentDateTime": "2018-02-25T21:46:00.000+0000"}, "name": "Uttam Anand", "age": 29}
hi
hi
uttam
hi
hi
hi
hello
hi
^CProcessed a total of 17 messages
1 回答
在使用bootstrap-server参数从kafka消费消息时,连接通过kafka服务器而不是zookeeper发生 . Kafka经纪人在__consumer_offsets主题中存储偏移细节 .
检查主题列表中是否存在__consumer_offsets . 如果它不存在,请检查kafka日志以找到原因 .
我们遇到了类似的问题 . 在我们的例子中,由于以下错误,未创建__consumer_offsets: