微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

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

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

$ 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 错误

解决方法

您需要安装 kafka-python,而不是 kafka 软件包

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

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。