diff --git a/faust/transport/drivers/aiokafka.py b/faust/transport/drivers/aiokafka.py index c0ab96dfe..0747c4474 100644 --- a/faust/transport/drivers/aiokafka.py +++ b/faust/transport/drivers/aiokafka.py @@ -42,7 +42,7 @@ for_code, ) from kafka.partitioner.default import DefaultPartitioner -from kafka.partitioner.hashed import murmur2 +from kafka.partitioner.default import murmur2 from kafka.protocol.metadata import MetadataRequest_v1 from mode import Service, get_logger from mode.utils.futures import StampedeWrapper