在mac上的Python3.8.5上导入kafkaproducer时，在self.async上出现语法错误

fkvaft9z 于 2021-06-04 发布在 Kafka

关注(0)|答案(1)|浏览(791)

当我运行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

你知道怎么纠正那个错误吗？

python apache-kafka python-3.x kafka-producer-api

来源：https://stackoverflow.com/questions/63773535/got-syntaxerror-around-self-async-while-import-kafkaproducer-on-python-3-8-5-on

1条答案

按热度按时间

yv5phkfx1#

我也有同样的问题。我改了模块名。
为了消费者，我用这个代替Kafka

from kafka.consumer import KafkaConsumer

同样，对于制片人，我用了这个

from kafka.producer import KafkaProducer

赞(0）回复(0）举报 2021-06-04

我来回答

在mac上的Python3.8.5上导入kafkaproducer时，在self.async上出现语法错误

1条答案

相关问题

热门标签

最新问答