From 78d2e8f093680748d743d3f81358cf27a1298c6b Mon Sep 17 00:00:00 2001
From: Wang Zhi <yfwz100@yeah.net>
Date: Fri, 25 Aug 2023 18:58:05 +0800
Subject: [PATCH] feat: add TLS config for kafka producer.

---
 pkg/common/kafka/producer.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/pkg/common/kafka/producer.go b/pkg/common/kafka/producer.go
index 938757d40..b7ec32714 100644
--- a/pkg/common/kafka/producer.go
+++ b/pkg/common/kafka/producer.go
@@ -60,6 +60,7 @@ func NewKafkaProducer(addr []string, topic string) *Producer {
 	}
 	p.addr = addr
 	p.topic = topic
+	SetupTLSConfig(p.config)
 	var producer sarama.SyncProducer
 	var err error
 	for i := 0; i <= maxRetry; i++ {