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后,它就会抛出错误。
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后,它就会抛出错误。
嗨,要解决这个问题,您必须安装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
我遇到了同样的问题。
如果已经安装了 Kafka
和 kafka-python
,但仍然遇到此问题,请检查您使用的 Python 版本。例如,kafka-python
可以安装在 python3
中,但您正在尝试使用 python2
执行脚本。
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,但现在已不再维护。