3
我安装了Python的kafka-python软件包。我有一个卡夫卡生产者和消费者正在运行。我想要python代码来读取kafka主题并打印出消息。Python错误:无法导入名称KafkaConsumer
我的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()
我得到以下错误:上什么,我在这里失踪
C:\Python27>python.exe kafka.py Traceback (most recent call last): File "kafka.py", line 2, in <module>
from kafka import KafkaConsumer File "C:\Python27\kafka.py", line 2, in <module>
from kafka import KafkaConsumer ImportError: cannot import name KafkaConsumer
有什么建议?
那帮了!不能相信这是一个天真的错误!感谢您的详细解释。 –