Add batch timeout to segmentio produce config

Trendyol · Jan 9, 2023 · d83dd5e · d83dd5e
1 parent 1dc1246
commit d83dd5e
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/kafka/producer/producer.go b/kafka/producer/producer.go
@@ -32,6 +32,7 @@ func NewProducer(config *config.Kafka, logger logger.Logger, errorLogger logger.
 		Balancer:     &kafka.Hash{},
 		BatchSize:    config.ProducerBatchSize,
 		BatchBytes:   math.MaxInt,
+		BatchTimeout: 500 * time.Microsecond,
 		MaxAttempts:  math.MaxInt,
 		ReadTimeout:  config.ReadTimeout,
 		WriteTimeout: config.WriteTimeout,