diff --git a/faust/transport/drivers/aiokafka.py b/faust/transport/drivers/aiokafka.py index 1c7c5fa13..e176fe3b4 100644 --- a/faust/transport/drivers/aiokafka.py +++ b/faust/transport/drivers/aiokafka.py @@ -1242,7 +1242,6 @@ def _new_producer( self, transactional_id: Optional[str] = None ) -> aiokafka.AIOKafkaProducer: return self._producer_type( - loop=self.loop, **{ **self._settings_default(), **self._settings_auth(), diff --git a/tests/unit/transport/drivers/test_aiokafka.py b/tests/unit/transport/drivers/test_aiokafka.py index 04d5d910f..35fe87ba4 100644 --- a/tests/unit/transport/drivers/test_aiokafka.py +++ b/tests/unit/transport/drivers/test_aiokafka.py @@ -1391,7 +1391,6 @@ def assert_new_producer( max_request_size=max_request_size, compression_type=compression_type, security_protocol=security_protocol, - loop=producer.loop, partitioner=producer.partitioner, transactional_id=None, api_version=api_version,