diff --git a/Kafka/Producer.php b/Kafka/Producer.php index 4521983c..0e57cb10 100644 --- a/Kafka/Producer.php +++ b/Kafka/Producer.php @@ -60,7 +60,7 @@ class Producer extends Component */ public function setAck(bool $value) { - $this->topicConf->set('request.required.acks', (int)$value); + $this->topicConf->set('request.required.acks', (string)$value); return $this; }