Python Kafka 报错:ImportError: cannot import name 'KafkaConsumer'

用户头像
Young先生
关注
发布于: 2020 年 07 月 23 日
Python Kafka 报错:ImportError: cannot import name 'KafkaConsumer'

在Django的项目中安装了kafka-python,但是不能正常运行,直接就报错了。



import sys
from kafka import KafkaConsumer
def kafkatest():
print "Step 1 complete"
consumer=KafkaConsumer('test',bootstrap_servers=['localhost:9092'])
for message in consumer:
print "Next message"
print message
if __name__=="__main__":
kafkatest()



然后在使用时,报错提示:ImportError: cannot import name 'KafkaConsumer'



找了半天没有找到解决方案,最后发现自己创建的文件名叫做:kafka.py,突然意识到问题出在哪里了。



原因:

简单说就是因为,创建的文件名是kafka.py,这会导致代码运行时,python解释器查找kafka的模块时,就找到自身(kafka.py)了,所以就报错。



解决办法:



修改文件名字为其他名字,比如:com_kafka.py,在运行就可以运行了。



本文首发于:BigYoung小站(http://www.bigyoung.cn)

发布于: 2020 年 07 月 23 日 阅读数: 11
用户头像

Young先生

关注

Python工程师/书虫/极客/ 2020.04.22 加入

伸手摘星,即使徒劳无功,也不至于满手泥污。 欢迎大家访问我的BigYoung小站(bigyoung.cn)

评论

发布
暂无评论
Python Kafka 报错:ImportError: cannot import name 'KafkaConsumer'