From db8834a26de01e648def3a5833c4187836e22c6d Mon Sep 17 00:00:00 2001 From: kytool Date: Mon, 22 Dec 2025 16:25:20 +0800 Subject: [PATCH] fix(sink): CloseIdleConnections when close kafka writer --- pkg/sink/kafka/sink.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/pkg/sink/kafka/sink.go b/pkg/sink/kafka/sink.go index 660a0ed87..eca2b31e7 100644 --- a/pkg/sink/kafka/sink.go +++ b/pkg/sink/kafka/sink.go @@ -118,6 +118,11 @@ func (s *Sink) Start() error { func (s *Sink) Stop() { if s.writer != nil { _ = s.writer.Close() + if s.writer.Transport != nil { + if transport, ok := s.writer.Transport.(*kafka.Transport); ok { + transport.CloseIdleConnections() + } + } } }