From 10969b050f0fecf47beb2076632be9030a5a936d Mon Sep 17 00:00:00 2001
From: stlc-shihh <huang.shihao@shuluntc.com>
Date: Fri, 26 Dec 2025 11:13:14 +0800
Subject: [PATCH] fix(broker): change the call of broker.kick from send to
 send_and_wait

---
 taskiq_aio_kafka/broker.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/taskiq_aio_kafka/broker.py b/taskiq_aio_kafka/broker.py
index 8f0fbd4..08806db 100644
--- a/taskiq_aio_kafka/broker.py
+++ b/taskiq_aio_kafka/broker.py
@@ -196,7 +196,7 @@ async def kick(self, message: BrokerMessage) -> None:
 
         topic_name: str = self._kafka_topic.name
 
-        await self._aiokafka_producer.send(
+        await self._aiokafka_producer.send_and_wait(
             topic=topic_name,
             value=message.message,
         )