fix: Close leaked health check kafka producer (milvus-io#37728)

Related to milvus-io#36822 Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
LoveEachDay · Nov 16, 2024 · 4820dd7 · 4820dd7
1 parent 3f7352f
commit 4820dd7
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/mq/msgstream/msgstream_util.go b/pkg/mq/msgstream/msgstream_util.go
@@ -114,6 +114,7 @@ func KafkaHealthCheck(clusterStatus *pcommon.MQClusterStatus) {
 		clusterStatus.Reason = fmt.Sprintf("failed to create Kafka producer: %v", err)
 		return
 	}
+	defer producer.Close()
 
 	metadata, err := producer.GetMetadata(nil, false, 3000)
 	if err != nil {