From b157cae73d5fd6dc4ffad8c6e5416a8dc37ff0b3 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=90=B4=E6=9B=A6?= <wuxi@lf-network.com>
Date: Wed, 30 Jul 2025 21:04:53 +0800
Subject: [PATCH] Add retry configuration for Kafka producer

---
 publish/kafka.php | 4 ++++
 src/Producer.php  | 2 ++
 2 files changed, 6 insertions(+)

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']);