python3 消费kafka数据

运行环境是python3.7
利用kafka-python包 消费kafka数据
程序一直消费不到数据
端口与主题都没有问题 已经确定是有数据的 就是消费不到数据
应该怎么处理呢

写成for msg in consumer:print("Topic Name=%s,Message=%s"%(msg.topic,msg.value))这样试试，参考这里怎样用python读取kafka数据，https://linuxhint.com/read_data_kafka_python/

如有用，请点击采纳。