pip - 已经安装kafka-python ，ImportError: cannot import name KafkaConsumer

Question

已经安装kafka-python (1.3.2.dev0)版本，但是ImportError: cannot import name KafkaConsumer

from kafka import KafkaConsumer
consumer = KafkaConsumer('test')
for msg in consumer:

print(msg)

http://kafka-python.readthedo...按照文档使用的为啥啊

Answer 1

github 마스터에서 설치해야 합니다. KafkaProducer는 아직 pypi에 출시되지 않았습니다.
https://github.com/dpkp/kafka...