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

Question

$ docker run 34a24a8a745e
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 错误

Answer 1

您需要安装kafka-python，而不是kafka打包

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