python-kafka接收不到消息

问题：

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

比如：

import json
from kafka import KafkaConsumer


consumer = KafkaConsumer('top_canal_test',group_id=None,bootstrap_servers=['10.211.55.6:9092'],auto_offset_reset='earliest')
for msg in consumer:
    recv = "%s:%d:%d: key=%s value=%s" % (msg.topic, msg.partition, msg.offset, msg.key, msg.value)
    print(recv)
    print("接收成功")

简单的一个demo,

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

原因：

没有配置正确配置listeners，advertised.listeners

具体可以看官方文档，网上参考资料也很多