diff --git a/Kafka/Producer.php b/Kafka/Producer.php index 3e1b7918..8ac377a4 100644 --- a/Kafka/Producer.php +++ b/Kafka/Producer.php @@ -96,6 +96,9 @@ class Producer extends Component $this->setTopicAcks($isAck); $this->push($message, $key); + if ($isAck) { + $this->flush(); + } }