fix

Signed-off-by: Song Gao <[email protected]>
lf-edge · Jan 10, 2025 · 7996a00 · 7996a00
1 parent 1387b36
commit 7996a00
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/extensions/sinks/kafka/ext/kafka.go b/extensions/sinks/kafka/ext/kafka.go
@@ -324,7 +324,7 @@ func getDefaultKafkaConf() *kafkaConf {
 		MaxAttempts:  1,
 		WriterConf: kafkaWriterConf{
 			BatchSize:    100,
-			BatchTimeout: time.Millisecond,
+			BatchTimeout: 5 * time.Millisecond,
 			BatchBytes:   1048576,
 		},
 	}