小编Abh*_*Owk的帖子

我为Python安装了kafka-python包.我有一个kafka制作人和消费者正在运行.我希望python代码读取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()

我收到以下错误:

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

关于我在这里缺少什么的任何建议？