fix: remove Confluent producer logger

faststream/confluent/broker/broker.py

@@ -47,7 +47,6 @@
         LoggerProto,
         SendableMessage,
     )
-    from faststream._internal.setup.state import BaseState
     from faststream._internal.types import (
         BrokerMiddleware,
         CustomCallable,
@@ -60,14 +59,14 @@
 
 
 class KafkaBroker(
+    KafkaRegistrator,
     BrokerUsecase[
         Union[
             confluent_kafka.Message,
             Tuple[confluent_kafka.Message, ...],
         ],
         Callable[..., AsyncConfluentConsumer],
     ],
-    KafkaRegistrator,
 ):
     url: List[str]
     _producer: Optional[AsyncConfluentFastProducer]
@@ -446,7 +445,6 @@ async def _connect(  # type: ignore[override]
         native_producer = AsyncConfluentProducer(
             **kwargs,
             client_id=client_id,
-            logger=self._state.logger_state,
             config=self.config,
         )
 
@@ -468,11 +466,6 @@ async def start(self) -> None:
         self._setup()
         await super().start()
 
-    def _setup(self, state: Optional["BaseState"] = None) -> None:
-        super()._setup(state)
-        if self._producer:
-            self._producer._setup(self._state.logger_state)
-
     @property
     def _subscriber_setup_extra(self) -> "AnyDict":
         return {

faststream/confluent/client.py

@@ -111,14 +111,8 @@ def __init__(
                 }
             )
 
-        self.config = final_config
-        self.__running = False
+        self.producer = Producer(final_config)
 
-    def _setup(self, logger_state: "LoggerState") -> None:
-        self.producer = Producer(
-            self.config,
-            logger=logger_state.logger.logger,
-        )
         self.__running = True
         self._poll_task = asyncio.create_task(self._poll_loop())
 

faststream/confluent/publisher/producer.py

@@ -10,7 +10,6 @@
 
 if TYPE_CHECKING:
     from faststream._internal.basic_types import SendableMessage
-    from faststream._internal.setup.logger import LoggerState
     from faststream._internal.types import CustomCallable
     from faststream.confluent.client import AsyncConfluentProducer
 
@@ -31,9 +30,6 @@ def __init__(
         self._parser = resolve_custom_func(parser, default.parse_message)
         self._decoder = resolve_custom_func(decoder, default.decode_message)
 
-    def _setup(self, logger_state: "LoggerState") -> None:
-        self._producer._setup(logger_state)
-
     @override
     async def publish(  # type: ignore[override]
         self,

faststream/kafka/broker/broker.py

@@ -231,11 +231,11 @@ class KafkaInitKwargs(TypedDict, total=False):
 
 
 class KafkaBroker(
+    KafkaRegistrator,
     BrokerUsecase[
         Union[aiokafka.ConsumerRecord, Tuple[aiokafka.ConsumerRecord, ...]],
         Callable[..., aiokafka.AIOKafkaConsumer],
     ],
-    KafkaRegistrator,
 ):
     url: List[str]
     _producer: Optional["AioKafkaFastProducer"]

faststream/nats/broker/broker.py

@@ -215,8 +215,8 @@ class NatsInitKwargs(TypedDict, total=False):
 
 
 class NatsBroker(
-    BrokerUsecase[Msg, Client],
     NatsRegistrator,
+    BrokerUsecase[Msg, Client],
 ):
     """A class to represent a NATS broker."""
 

faststream/rabbit/broker/broker.py

@@ -60,8 +60,8 @@
 
 
 class RabbitBroker(
-    BrokerUsecase[IncomingMessage, RobustConnection],
     RabbitRegistrator,
+    BrokerUsecase[IncomingMessage, RobustConnection],
 ):
     """A class to represent a RabbitMQ broker."""
 

faststream/redis/broker/broker.py

@@ -85,8 +85,8 @@ class RedisInitKwargs(TypedDict, total=False):
 
 
 class RedisBroker(
-    BrokerUsecase[UnifyRedisDict, "Redis[bytes]"],
     RedisRegistrator,
+    BrokerUsecase[UnifyRedisDict, "Redis[bytes]"],
 ):
     """Redis broker."""