diff --git a/faststream/confluent/client.py b/faststream/confluent/client.py index 76a3073410..38e5f33175 100644 --- a/faststream/confluent/client.py +++ b/faststream/confluent/client.py @@ -112,7 +112,7 @@ def __init__( } ) - self.producer = Producer(final_config, logger=self.logger) + self.producer = Producer(final_config, logger=self.logger) # type: ignore[call-arg] self.__running = True self._poll_task = asyncio.create_task(self._poll_loop()) @@ -312,7 +312,7 @@ def __init__( ) self.config = final_config - self.consumer = Consumer(final_config, logger=self.logger) + self.consumer = Consumer(final_config, logger=self.logger) # type: ignore[call-arg] @property def topics_to_create(self) -> List[str]: