confluent: check producer before setup

airtai · Sep 20, 2024 · 71a1634 · 71a1634
1 parent bfca156
commit 71a1634
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/faststream/confluent/broker/broker.py b/faststream/confluent/broker/broker.py
@@ -470,7 +470,8 @@ async def start(self) -> None:
 
     def _setup(self, state: Optional["BaseState"] = None) -> None:
         super()._setup(state)
-        self._producer._setup(self._state.logger_state)
+        if self._producer:
+            self._producer._setup(self._state.logger_state)
 
     @property
     def _subscriber_setup_extra(self) -> "AnyDict":