ImportError: cannot import name 'ConsumerRebalanceListener' from 'kafka' (/app/kafka/__init__.py)

[ali-albuhussain]

Checklist

• [x] I have included information about relevant versions
• [ ] I have verified that the issue persists when using the master branch of Faust.

Steps to reproduce

just started a simple consumer worker.

Actual behavior

won't start and keeps failing, see the stack trace for more details.

Full traceback

microservice_1  |   File "/usr/local/bin/faust", line 5, in <module>
microservice_1  |     from faust.cli.faust import cli
microservice_1  |   File "/usr/local/lib/python3.7/site-packages/faust/cli/faust.py", line 8, in <module>
microservice_1  |     from .livecheck import livecheck
microservice_1  |   File "/usr/local/lib/python3.7/site-packages/faust/cli/livecheck.py", line 4, in <module>
microservice_1  |     from .worker import worker
microservice_1  |   File "/usr/local/lib/python3.7/site-packages/faust/cli/worker.py", line 16, in <module>
microservice_1  |     from faust.worker import Worker as FaustWorker
microservice_1  |   File "/usr/local/lib/python3.7/site-packages/faust/worker.py", line 18, in <module>
microservice_1  |     from aiokafka.structs import TopicPartition
microservice_1  |   File "/usr/local/lib/python3.7/site-packages/aiokafka/__init__.py", line 3, in <module>
microservice_1  |     from .abc import ConsumerRebalanceListener
microservice_1  |   File "/usr/local/lib/python3.7/site-packages/aiokafka/abc.py", line 2, in <module>
microservice_1  |     from kafka import ConsumerRebalanceListener as BaseConsumerRebalanceListener
microservice_1  | ImportError: cannot import name 'ConsumerRebalanceListener' from 'kafka' (/app/kafka/__init__.py)

Versions

• Python version 3.8, 3.7, 3.9
• Faust version 0.6.10
• Operating system ubuntu
• Kafka version
• RocksDB version (if applicable)