How to resolve SyntaxError in kafka module?

Asked Aug 23 '21 at 07:25

Active Aug 23 '21 at 11:50

Viewed 71 times

I updated to kafka-python, now I get the following error:

Traceback (most recent call last):
  File "app.py", line 2, in <module>
    from kafka import KafkaConsumer
ImportError: cannot import name 'KafkaConsumer' from 'kafka' (unknown location)

Previously, when I got the following error, it might have been due to outdated kafka module.

Traceback (most recent call last):
  File "app.py", line 2, in <module>
    from kafka import KafkaConsumer
  File "/home/vijay/lehra/.venv/lib/python3.8/site-packages/kafka/__init__.py", line 23, in <module>
    from kafka.producer import KafkaProducer
  File "/home/vijay/lehra/.venv/lib/python3.8/site-packages/kafka/producer/__init__.py", line 4, in <module>
    from .simple import SimpleProducer
  File "/home/vijay/lehra/.venv/lib/python3.8/site-packages/kafka/producer/simple.py", line 54
    return '<SimpleProducer batch=%s>' % self.async
                                              ^
SyntaxError: invalid syntax

edited Aug 23 '21 at 11:50

OneCricketeer

179,855
19
132
245

asked Aug 23 '21 at 07:25

Vijay Kumar

2

Does this answer your question? [SyntaxError on "self.async" when running python kafka producer](https://stackoverflow.com/questions/65809459/syntaxerror-on-self-async-when-running-python-kafka-producer) – abhigyanj Aug 23 '21 at 07:27
what cmd did you use to install it? – sid Aug 23 '21 at 07:27
1

The code of the library seems to be older. It is not compatible with recent Python versions that support the `async` keyword. – Klaus D. Aug 23 '21 at 07:31
updated code library, now it giver ImportError – Vijay Kumar Aug 23 '21 at 08:08
Is your module or another file in your module named kafka.py? – wxker Aug 23 '21 at 09:37
No. There's only one file "app.py" – Vijay Kumar Aug 23 '21 at 09:44
The error indicates that you never uninstalled `kafka` before you installed `kafka-python` – OneCricketeer Aug 23 '21 at 11:49
So, I reinstalled kafka-python and it worked. Why didn't it work before? I have had very limited exposure to Linux. – Vijay Kumar Aug 23 '21 at 13:04

How to resolve SyntaxError in kafka module?

0 Answers0