我正在努力import KafkaConsumer from kafka。
它说:
没有名为 kafka 的模块
from kafka import KafkaConsumer
import sys
consumer = KafkaConsumer('test', bootstrap_servers='10.221.129.223')
Run Code Online (Sandbox Code Playgroud)
root@ubuntu-14:~/kafka_2.11-0.8.2.1# ls bin config libs 许可证通知 test.py
有什么建议?因为这在某个时候工作正常。安装最新版本的 kafka 后,它会引发此错误。