fix #1959: propagate logger to Confluent (#1960)

* fix #1959: propagate logger to Confluent * lint: fix mypy
airtai · Dec 4, 2024 · f01bfcb · f01bfcb
1 parent b1c6fa2
commit f01bfcb
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git 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
@@ -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]: