From 305f78edd376d88c468ae37a6975ce9f3357afec Mon Sep 17 00:00:00 2001 From: "dat.dao" Date: Sun, 24 Nov 2019 11:12:23 +0700 Subject: [PATCH] =?UTF-8?q?[Config]=20T=C4=83ng=20s=E1=BB=91=20l=E1=BA=A7n?= =?UTF-8?q?=20retry=20c=E1=BB=A7a=20producer=20l=C3=AAn=2010?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- sarama.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/sarama.go b/sarama.go index e2efbe3..a9ae4c0 100644 --- a/sarama.go +++ b/sarama.go @@ -21,6 +21,9 @@ func NewConfig() *sarama.Config { cfg.Producer.Flush.MaxMessages = 1 cfg.Producer.Return.Successes = true + cfg.Producer.Retry.Max = 10 + cfg.Producer.Retry.Backoff = time.Second + return cfg }