运行 python kafka 生产者时“self.async”上的 SyntaxError答案

【问题标题】：SyntaxError on "self.async" when running python kafka producer运行 python kafka 生产者时“self.async”上的 SyntaxError
【发布时间】：2021-01-20 12:21:08
【问题描述】：

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

我之前看到过相同的错误，但我使用的是from kafka import KafkaProducer

我的新 python 脚本使用 from kafka.producer import KafkaProducer但我仍然收到 self.async 错误

【问题讨论】：

能分享一下代码sn-p
对不起，我已经解决了我使用 kafka-python 库而不是 kafka 并更新了我的 docker 文件以使用解决问题的最新 python 版本
async 是保留字。 docs.python.org/3/reference/….

标签： python python-3.x kafka-python

【解决方案1】：

您需要安装kafka-python，而不是kafka 包。如果安装了kafka，则需要卸载并替换为其他的

https://github.com/dpkp/kafka-python/issues/1566

【讨论】：