From db53547181bdfde1daca3c8535e2770509bc5172 Mon Sep 17 00:00:00 2001 From: lucas Date: Tue, 8 Jul 2025 17:26:05 +0800 Subject: [PATCH] =?UTF-8?q?update=20=E5=BB=B6=E9=95=BF=E8=B6=85=E6=97=B6?= =?UTF-8?q?=E6=97=B6=E9=97=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- dbOperate/_kafka/producerHelper.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/dbOperate/_kafka/producerHelper.go b/dbOperate/_kafka/producerHelper.go index 9844c95..41ea632 100644 --- a/dbOperate/_kafka/producerHelper.go +++ b/dbOperate/_kafka/producerHelper.go @@ -98,9 +98,9 @@ func (p *KafkaAsyncProducer) Close() { func NewKafkaAsyncProducer(brokers []string, clientID string) *KafkaAsyncProducer { config := sarama.NewConfig() config.ClientID = clientID - config.Net.DialTimeout = time.Second * 10 - config.Net.ReadTimeout = time.Second * 10 - config.Net.WriteTimeout = time.Second * 10 + config.Net.DialTimeout = time.Second * 30 + config.Net.ReadTimeout = time.Second * 30 + config.Net.WriteTimeout = time.Second * 30 producer, err := sarama.NewAsyncProducer(brokers, config) if err != nil { log.Printf("_kafka 生产者[%v] 初始化异常 %s", brokers, err.Error())