pythonkafka接收不到消息

问题&＃xff1a;

使用python-kafka 消费者不能订阅到生成的消息

比如&＃xff1a;

import json
from kafka import KafkaConsumerconsumer &＃61; KafkaConsumer(&＃39;top_canal_test&＃39;,group_id&＃61;None,bootstrap_servers&＃61;[&＃39;10.211.55.6:9092&＃39;],auto_offset_reset&＃61;&＃39;earliest&＃39;)
for msg in consumer:recv &＃61; "%s:%d:%d: key&＃61;%s value&＃61;%s" % (msg.topic, msg.partition, msg.offset, msg.key, msg.value)print(recv)print("接收成功")

简单的一个demo,

使用&＃xff1a;./kafka-console-consumer.sh --topic 能看到生产者出现的消息&＃xff0c;但是这个demo没有发生数据。

原因&＃xff1a;

没有配置正确配置listeners&＃xff0c;advertised.listeners

具体可以看官方文档&＃xff0c;网上参考资料也很多