在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小站
搞代码网（gaodaima.com）提供的所有资源部分来自互联网，如果有侵犯您的版权或其他权益，请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected]，我们会在看到邮件的第一时间内为您处理，或直接联系QQ：872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接：关于python:Python-Kafka-报错ImportError-cannot-import-name-KafkaConsumer
转载请注明原文链接：关于python:Python-Kafka-报错ImportError-cannot-import-name-KafkaConsumer
