在Django项目中安装了kafka-python，但是无法正常运行，直接报错。importsysfromkafkaimportKafkaConsumerdefkafkatest():print"Step1complete"consumer=KafkaConsumer('test',bootstrap_servers=['localhost:9092'])formessageinconsumer:print"Nextmessage"printmessageif__name__=="__main__":kafkatest()然后在使用的时候报错：ImportError:cannotimportname'KafkaConsumer'找了半天也没找到解决办法。最后发现我创建的文件名叫：kafka.py，我一下子意识到问题出在哪里了。.原因：简单来说就是因为创建的文件名为kafka.py，会导致python解释器在代码运行时搜索kafka模块时找不到自己（kafka.py），从而报错。解决方法：将文件名修改为其他名称，如：com_kafka.py，运行后即可运行。
