已经安装kafka-python (1.3.2.dev0)版本,但是ImportError: cannot import name KafkaConsumer
from kafka import KafkaConsumerconsumer = KafkaConsumer('test')for msg in consumer:
print(msg)
http://kafka-python.readthedo...按照文档使用的为啥啊
ringa_lee
你需要从github master安装 - KafkaProducer还没有发布到pypi。https://github.com/dpkp/kafka...
你需要从github master安装 - KafkaProducer还没有发布到pypi。
https://github.com/dpkp/kafka...