Merge pull request #3 from tikivn/config/kafka_time_out

[Config] Tăng số lần retry của producer lên 10
tikivn · Nov 25, 2019 · f16c1b9 · f16c1b9
2 parents d600b8a + 305f78e
commit f16c1b9
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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
 }