From 7ecdf20f53f52fd74de0242cddd917ecf88d762f Mon Sep 17 00:00:00 2001 From: Rishikesh Jha Date: Tue, 12 Jan 2021 22:58:56 +0530 Subject: [PATCH] fix(Issue-697): Fixing few things for adding support for kafka-python 2.0.0 --- faust/transport/drivers/aiokafka.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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