From 6d28a6f6128e3eca628388be367d1c08ac564d34 Mon Sep 17 00:00:00 2001
From: Wang Zhi <yfwz100@yeah.net>
Date: Fri, 25 Aug 2023 18:24:25 +0800
Subject: [PATCH] feat: setup TLS config for kafka consumer.

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

diff --git a/pkg/common/kafka/consumer.go b/pkg/common/kafka/consumer.go
index 67bc3977b..e253ec5e0 100644
--- a/pkg/common/kafka/consumer.go
+++ b/pkg/common/kafka/consumer.go
@@ -40,6 +40,7 @@ func NewKafkaConsumer(addr []string, topic string) *Consumer {
 		consumerConfig.Net.SASL.User = config.Config.Kafka.Username
 		consumerConfig.Net.SASL.Password = config.Config.Kafka.Password
 	}
+	SetupTLSConfig(consumerConfig)
 	consumer, err := sarama.NewConsumer(p.addr, consumerConfig)
 	if err != nil {
 		panic(err.Error())