diff --git a/publish/kafka.php b/publish/kafka.php index a79b5b6..82b9f18 100644 --- a/publish/kafka.php +++ b/publish/kafka.php @@ -28,6 +28,10 @@ 'acks' => -1, 'producer_id' => -1, 'producer_epoch' => -1, + 'produce' => [ + 'retry' => 3, + 'retry_sleep' => 0.1, + ], 'partition_leader_epoch' => -1, 'interval' => 0, 'session_timeout' => 60, diff --git a/src/Producer.php b/src/Producer.php index 3ea13a9..f3e28f9 100644 --- a/src/Producer.php +++ b/src/Producer.php @@ -172,6 +172,8 @@ private function makeProducer(): LongLangProducer $producerConfig->setAcks($config['acks']); $producerConfig->setProducerId($config['producer_id']); $producerConfig->setProducerEpoch($config['producer_epoch']); + $producerConfig->setProduceRetry($config['produce']['retry']); + $producerConfig->setProduceRetrySleep($config['produce']['retry_sleep']); $producerConfig->setPartitionLeaderEpoch($config['partition_leader_epoch']); $producerConfig->setAutoCreateTopic($config['auto_create_topic']); ! empty($config['sasl']) && $producerConfig->setSasl($config['sasl']);