【发布时间】:2020-04-16 04:30:18
【问题描述】:
我已经使用pip install安装了最新版本的Kafka
Installing collected packages: kafka
Successfully installed kafka-1.3.5
当我尝试import KafkaProducer 时,它给了我错误:
File "//anaconda3/lib/python3.7/site-packages/kafka/producer/__init__.py", line 2, in <module>
from .simple import SimpleProducer
File "//anaconda3/lib/python3.7/site-packages/kafka/producer/simple.py", line 54
return '<SimpleProducer batch=%s>' % self.async
^
我也尝试了其他两个版本,但似乎都给出了类似的错误。 SyntaxError: 无效语法
【问题讨论】:
-
嗯,就是这样:
async现在是关键字,所以不能用作属性名。检查您是否安装了最新版本的库并且它是否支持您的 Python 版本(看起来不支持) -
@ForceBru,我明白了,但我使用的是前面提到的版本 1.3.5 和 Python 版本 3.4+,理想情况下版本兼容性应该不是问题。
-
here 它显示“Python 3.4, 3.5, 3.6”,因此不支持您的版本 (3.7)。事实上,在 Python 3.6 中,
async和await不是关键字,这与 3.7 不同 -
顺便说一句,还有其他适用于python的Kafka库
标签: python apache-kafka kafka-producer-api kafka-python