fix

Signed-off-by: Song Gao <disxiaofei@163.com>
lf-edge · Jan 10, 2025 · 8d62986 · 8d62986
1 parent 7996a00
commit 8d62986
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/extensions/sinks/kafka/ext/kafka.go b/extensions/sinks/kafka/ext/kafka.go
@@ -135,6 +135,7 @@ func (m *kafkaSink) buildKafkaWriter() error {
 			TLS:  m.tlsConfig,
 		},
 	}
+	conf.Log.Infof("kafka writer batchSize:%v, batchTimeout:%v", m.kc.WriterConf.BatchSize, m.kc.WriterConf.BatchTimeout.String())
 	m.writer = w
 	return nil
 }