Fix: typo

airtai · Sep 17, 2024 · 6dadac7 · 6dadac7
1 parent 5463d77
commit 6dadac7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/faststream/confluent/broker/broker.py b/faststream/confluent/broker/broker.py
@@ -516,7 +516,7 @@ async def request(  # type: ignore[override]
     ) -> Optional[Any]:
         correlation_id = correlation_id or gen_cor_id()
 
-        await super().request(
+        return await super().request(
             message,
             producer=self._producer,
             topic=topic,