python - 在 mac 上的 python 3.8.5 上导入 KafkaProducer 时，self.async 出现 SyntaxError

Question

当我运行我的 python 脚本时，我收到一个关于from kafka import KafkaProducer. 我的错误看起来像：

Traceback (most recent call last):
  File "FatEvent.py", line 1, in <module>
    from kafka import KafkaProducer
  File "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/site-packages/kafka/__init__.py", line 23, in <module>
    from kafka.producer import KafkaProducer
  File "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/site-packages/kafka/producer/__init__.py", line 4, in <module>
    from .simple import SimpleProducer
  File "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/site-packages/kafka/producer/simple.py", line 54
    return '<SimpleProducer batch=%s>' % self.async
                                              ^
SyntaxError: invalid syntax

你知道如何解决这个错误吗？

Answer 1

我遇到过同样的问题。我更改了模块名称。

代替卡夫卡，对于消费者，我用这个

from kafka.consumer import KafkaConsumer

同样，对于生产者，我使用了这个

from kafka.producer import KafkaProducer

Answer 2

在我的情况下，它通过安装“kafka-python”包解决了。

python -m pip install kafka-python