diff --git a/faststream/_internal/broker/router.py b/faststream/_internal/broker/router.py
index 81f4a2998a..8c02459095 100644
--- a/faststream/_internal/broker/router.py
+++ b/faststream/_internal/broker/router.py
@@ -84,7 +84,7 @@ def __init__(
             decoder=decoder,
             include_in_schema=include_in_schema,
             state=EmptyBrokerState("You should include router to any broker."),
-            routers=routers
+            routers=routers,
         )
 
         for h in handlers:
diff --git a/faststream/confluent/broker/broker.py b/faststream/confluent/broker/broker.py
index a940f1c2aa..0262dbd9c3 100644
--- a/faststream/confluent/broker/broker.py
+++ b/faststream/confluent/broker/broker.py
@@ -454,7 +454,7 @@ async def _connect(  # type: ignore[override]
             **kwargs,
             client_id=client_id,
             config=self.config,
-            logger=self._state.get().logger_state
+            logger=self._state.get().logger_state,
         )
 
         self._producer.connect(native_producer)
diff --git a/tests/brokers/kafka/test_consume.py b/tests/brokers/kafka/test_consume.py
index 3c9bd4ca90..1c8ee55f99 100644
--- a/tests/brokers/kafka/test_consume.py
+++ b/tests/brokers/kafka/test_consume.py
@@ -399,7 +399,9 @@ async def handler(msg):
 
             await asyncio.wait(
                 (
-                    asyncio.create_task(br._producer._producer.producer.send(queue, key=b"")),
+                    asyncio.create_task(
+                        br._producer._producer.producer.send(queue, key=b"")
+                    ),
                     asyncio.create_task(event.wait()),
                 ),
                 timeout=3,
@@ -426,7 +428,9 @@ async def handler(msg):
 
             await asyncio.wait(
                 (
-                    asyncio.create_task(br._producer._producer.producer.send(queue, key=b"")),
+                    asyncio.create_task(
+                        br._producer._producer.producer.send(queue, key=b"")
+                    ),
                     asyncio.create_task(event.wait()),
                 ),
                 timeout=3,