From f01bfcb3ccf71467410ddc6ecb5b01d47f6159f9 Mon Sep 17 00:00:00 2001 From: Pastukhov Nikita Date: Wed, 4 Dec 2024 08:12:29 +0300 Subject: [PATCH] fix #1959: propagate logger to Confluent (#1960) * fix #1959: propagate logger to Confluent * lint: fix mypy --- faststream/__about__.py | 2 +- faststream/confluent/client.py | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/faststream/__about__.py b/faststream/__about__.py index dd7f6b0de2..bca873f17e 100644 --- a/faststream/__about__.py +++ b/faststream/__about__.py @@ -1,5 +1,5 @@ """Simple and fast framework to create message brokers based microservices.""" -__version__ = "0.5.31" +__version__ = "0.5.32" SERVICE_NAME = f"faststream-{__version__}" diff --git a/faststream/confluent/client.py b/faststream/confluent/client.py index db6f8370a2..38e5f33175 100644 --- a/faststream/confluent/client.py +++ b/faststream/confluent/client.py @@ -112,7 +112,7 @@ def __init__( } ) - self.producer = Producer(final_config) + 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) + self.consumer = Consumer(final_config, logger=self.logger) # type: ignore[call-arg] @property def topics_to_create(self) -> List[str]: