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,
         )