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'
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