diff --git a/extensions/sinks/kafka/ext/kafka.go b/extensions/sinks/kafka/ext/kafka.go index c5078e9e43..033e5c11d9 100644 --- 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, }, }