revert unnecessary changes.

pingcap · Jan 17, 2022 · 8c97d96 · 8c97d96
1 parent c8126ec
commit 8c97d96
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/cdc/sink/producer/kafka/config.go b/cdc/sink/producer/kafka/config.go
@@ -248,6 +248,7 @@ func newSaramaConfig(ctx context.Context, c *Config) (*sarama.Config, error) {
 	config.Producer.Return.Successes = true
 	config.Producer.Return.Errors = true
 	config.Producer.RequiredAcks = sarama.WaitForAll
+	// Time out in five minutes(600 * 500ms).
 	config.Producer.Retry.Max = 600
 	config.Producer.Retry.Backoff = 500 * time.Millisecond
 	switch strings.ToLower(strings.TrimSpace(c.Compression)) {