From 8d629868edb884cb567b40850015ec0938c74a3d Mon Sep 17 00:00:00 2001
From: Song Gao <disxiaofei@163.com>
Date: Fri, 10 Jan 2025 16:12:55 +0800
Subject: [PATCH] fix

Signed-off-by: Song Gao <disxiaofei@163.com>
---
 extensions/sinks/kafka/ext/kafka.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/extensions/sinks/kafka/ext/kafka.go b/extensions/sinks/kafka/ext/kafka.go
index 033e5c11d..53f83ce49 100644
--- 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
 }