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

Question

我正在努力

import KafkaConsumer from kafka

。

它说：

没有名为 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 许可证 注意测试.py

有什么建议吗？因为这在某个时候运行良好。安装最新版本的kafka后，它会抛出此错误。

Answer 1

您好，要解决此问题，您必须安装适用于 python 的 kafka 库：kafka-python

这是基于 linux/debian 的操作系统的命令

pip install kafka-python

我认为你还必须在你的操作系统上安装kafka。

https://www.digitalocean.com/community/tutorials/how-to-install-apache-kafka-on-ubuntu-14-04

Answer 2

我也有同样的问题。 如果

Kafka

和

kafka-python

已经安装并且您仍然遇到此问题，请检查您运行脚本所使用的 python 版本。 （例如，

kafka-python

可以安装在

python3

中，并且您尝试使用

python2

执行脚本）

Answer 3

kafka 库现在称为Kafka Python 客户端（官方文档）。

为了安装它，如果使用的是Anaconda（Anaconda官方网站上的软件包页面），则可以运行

conda install kafka-python

不然可以用

pip install kafka-python

有关如何安装的更多信息，查看此页面。

还有其他适用于 Kafka 的 Python 客户端，例如 Confluence 的 Python 客户端（官方文档）。

这个也可以在 PyPI 上使用，因此可以使用 pip 安装它，如下所示

pip install confluent-kafka

---

注释：

• 如果 Python 安装出现问题，使用 Anaconda Distribution 可能会解决问题。如果使用 Anaconda，建议在工作环境中使用

  conda install package

  ，仅当

  pip

  不可用时才使用

  conda install

  。

• 不久前有一个pykafka，但它不再维护了。

Answer 4

如果您在同一环境中同时安装

kafka-python

和

kafka

软件包，请尝试删除其中一个软件包并仅安装其中一个软件包。 （我只安装了

kafka

并卸载了

kafka-python

）

由于某种原因，在我的本地 conda env 上安装这两个软件包并没有导致任何问题（使用带有 M2 芯片的 MAC 操作系统），但尝试通过集群上的气流运行代码会引发相同的错误。