diff --git a/faststream/confluent/broker/broker.py b/faststream/confluent/broker/broker.py
index 299805cc3f..7b31cdf5ae 100644
--- 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,