faust icon indicating copy to clipboard operation
faust copied to clipboard

Not Compatible with kafka-python==2.0.0

Open Rishi-jha opened this issue 4 years ago • 0 comments

File "", line 219, in _call_with_frames_removed File "/home/rishi/.virtualenvs/virtualenv/lib/python3.7/site-packages/faust/transport/drivers/aiokafka.py", line 45, in from kafka.partitioner.hashed import murmur2 ModuleNotFoundError: No module named 'kafka.partitioner.hashed'

It should be kafka.partitioner.default instead

Rishi-jha avatar Jan 12 '21 17:01 Rishi-jha