diff --git a/Kafka/Producer.php b/Kafka/Producer.php
index 18444569..02c6191c 100644
--- a/Kafka/Producer.php
+++ b/Kafka/Producer.php
@@ -105,6 +105,7 @@ class Producer extends Component
 		/** @var \RdKafka\Producer $rk */
 		$rk = Snowflake::createObject(\RdKafka\Producer::class, [$this->conf]);
 		if ($rk->getOutQLen() > 0) {
+			$rk->poll(0);
 			$rk->flush($timeout);
 		}