From e4d7693af28dcb1269df2435db27f5a3be2b6cfc Mon Sep 17 00:00:00 2001
From: Wang Zhi <yfwz100@yeah.net>
Date: Fri, 25 Aug 2023 18:59:40 +0800
Subject: [PATCH] chore: add TLS config for kafka.

---
 pkg/common/config/config.go | 13 ++++++++++---
 1 file changed, 10 insertions(+), 3 deletions(-)

diff --git a/pkg/common/config/config.go b/pkg/common/config/config.go
index 754753b3b..c6dd41419 100644
--- a/pkg/common/config/config.go
+++ b/pkg/common/config/config.go
@@ -81,9 +81,16 @@ type configStruct struct {
 	} `yaml:"redis"`
 
 	Kafka struct {
-		Username         string   `yaml:"username"`
-		Password         string   `yaml:"password"`
-		Addr             []string `yaml:"addr"`
+		Username string   `yaml:"username"`
+		Password string   `yaml:"password"`
+		Addr     []string `yaml:"addr"`
+		TLS      *struct {
+			CACrt              string `yaml:"caCrt"`
+			ClientCrt          string `yaml:"clientCrt"`
+			ClientKey          string `yaml:"clientKey"`
+			ClientKeyPwd       string `yaml:"clientKeyPwd"`
+			InsecureSkipVerify bool   `yaml:"insecureSkipVerify"`
+		} `yaml:"tls"`
 		LatestMsgToRedis struct {
 			Topic string `yaml:"topic"`
 		} `yaml:"latestMsgToRedis"`