Got SyntaxError around self.async while import KafkaProducer on python 3.8.5 on mac

Question

when I run my python script, I got an error about from kafka import KafkaProducer. My error looks like:

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

Do you know how to fix that error?

Try using confluent_kafka instead? – OneCricketeer Sep 07 '20 at 19:06 — OneCricketeer, Sep 07 '20 at 19:06

score 3 · Answer 1 · answered Oct 02 '20 at 08:17

3

I had the same issue. I changed the module name.

In place of kafka, for consumer, I used this

from kafka.consumer import KafkaConsumer

Similarly, for producer, I used this

from kafka.producer import KafkaProducer

answered Oct 02 '20 at 08:17

Vineet Mishra

69
4

score 1 · Answer 2 · answered Apr 15 '21 at 05:35

1

In my case it solved by installing "kafka-python" package .

python -m pip install kafka-python

answered Apr 15 '21 at 05:35

adramazany

625
9
15

Got SyntaxError around self.async while import KafkaProducer on python 3.8.5 on mac

2 Answers2