已经安装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 마스터에서 설치해야 합니다. KafkaProducer는 아직 pypi에 출시되지 않았습니다. https://github.com/dpkp/kafka...
github 마스터에서 설치해야 합니다. KafkaProducer는 아직 pypi에 출시되지 않았습니다.
https://github.com/dpkp/kafka...