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

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

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

from kafka.consumer import KafkaConsumer

同样，对于producer，我用的是这个

from kafka.producer import KafkaProducer