From edff36bbcdf9b884bbd1bf2cf57e53a498dd19ea Mon Sep 17 00:00:00 2001
From: luhaoling <2198702716@qq.com>
Date: Mon, 26 Feb 2024 17:35:35 +0800
Subject: [PATCH] fix: fix the kafka of tls is nil problem

---
 tools/component/component.go | 15 +++++++++------
 1 file changed, 9 insertions(+), 6 deletions(-)

diff --git a/tools/component/component.go b/tools/component/component.go
index 53422c23e..bb3a2d46f 100644
--- a/tools/component/component.go
+++ b/tools/component/component.go
@@ -187,12 +187,15 @@ func checkKafka(config *config.GlobalConfig) error {
 		}
 	}
 
-	tlsConfig := &kafka.TLSConfig{
-		CACrt:              config.Kafka.TLS.CACrt,
-		ClientCrt:          config.Kafka.TLS.ClientCrt,
-		ClientKey:          config.Kafka.TLS.ClientKey,
-		ClientKeyPwd:       config.Kafka.TLS.ClientKeyPwd,
-		InsecureSkipVerify: config.Kafka.TLS.InsecureSkipVerify,
+	var tlsConfig *kafka.TLSConfig
+	if config.Kafka.TLS != nil {
+		tlsConfig = &kafka.TLSConfig{
+			CACrt:              config.Kafka.TLS.CACrt,
+			ClientCrt:          config.Kafka.TLS.ClientCrt,
+			ClientKey:          config.Kafka.TLS.ClientKey,
+			ClientKeyPwd:       config.Kafka.TLS.ClientKeyPwd,
+			InsecureSkipVerify: config.Kafka.TLS.InsecureSkipVerify,
+		}
 	}
 
 	_, err = kafka.NewMConsumerGroup(&kafka.MConsumerGroupConfig{