From 6dadac7ff0f0c583a1d9b39a4c719e81fa511103 Mon Sep 17 00:00:00 2001 From: Daniil Dumchenko Date: Wed, 18 Sep 2024 00:38:56 +0700 Subject: [PATCH] Fix: typo --- faststream/confluent/broker/broker.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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,