关于python: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 小站