已经安装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...按照文档使用的为啥啊
Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号
ringa_lee