导入错误:没有名为kafka的模块。

6
我正在尝试从kafka中导入KafkaConsumer。它显示:没有名为kafka的模块。
from kafka import KafkaConsumer
import sys

consumer = KafkaConsumer('test', bootstrap_servers='10.221.129.223')

root@ubuntu-14:~/kafka_2.11-0.8.2.1# ls bin config libs LICENSE NOTICE test.py

有什么建议吗?因为之前这个命令是可以正常工作的,但在安装了最新版本的kafka后,它就会抛出错误。

3个回答

11

3

我遇到了同样的问题。 如果已经安装了 Kafkakafka-python,但仍然遇到此问题,请检查您使用的 Python 版本。例如,kafka-python 可以安装在 python3 中,但您正在尝试使用 python2 执行脚本。


0

Kafka library现在被称为Kafka Python客户端官方文档)。

如果使用Anaconda(Anaconda官方网站上的软件包页面),则可以运行以下命令来安装它:

conda install kafka-python

否则,可以使用

pip install kafka-python

如需安装更多信息,请查看此页面

还有其他Python Kafka客户端,例如Confluent的Python客户端官方文档)。

此客户端也可在PyPI上获取,因此可以使用pip进行安装,方法如下:

pip install confluent-kafka

注意事项:

  • 如果安装Python时遇到问题,使用Anaconda Distribution可能会更容易。如果使用Anaconda,则建议在所使用的环境中使用conda install package,仅在conda install不可用时才使用pip

  • 一段时间以前,有人使用了pykafka,但现在已不再维护。


网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接