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{