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