fix: resolve silent logging failures in broker (#2691)

faststream/_internal/broker/broker.py

@@ -108,8 +108,8 @@ def _setup_logger(self) -> None:
     async def connect(self) -> ConnectionType:
         """Connect to a remote server."""
         if self._connection is None:
-            self._connection = await self._connect()
             self._setup_logger()
+            self._connection = await self._connect()
 
         return self._connection
 

faststream/confluent/configs/broker.py

@@ -62,7 +62,7 @@ async def connect(self) -> "None":
             logger=self.logger,
         )
         self.producer.connect(native_producer, serializer=self.fd_config._serializer)
-        await self.admin.connect(self.connection_config)
+        await self.admin.connect(self.connection_config, logger_state=self.logger)
 
     async def disconnect(self) -> "None":
         await self.producer.disconnect()

faststream/confluent/helpers/admin.py

@@ -7,6 +7,8 @@
 )
 
 if TYPE_CHECKING:
+    from faststream._internal.logger import LoggerState
+
     from .config import ConfluentFastConfig
 
 
@@ -20,9 +22,9 @@ class AdminService:
     def __init__(self) -> None:
         self.admin_client: AdminClient | None = None
 
-    async def connect(self, config: "ConfluentFastConfig") -> None:
+    async def connect(self, config: "ConfluentFastConfig", logger_state: "LoggerState") -> None:
         if self.admin_client is None:
-            self.admin_client = AdminClient(config.admin_config)
+            self.admin_client = AdminClient(config.admin_config, logger=logger_state.logger.logger)
 
     async def disconnect(self) -> None:
         self.admin_client = None