Separate kafka ca cert config from kafka sasl config

RedHatInsights · Oct 12, 2023 · e997e83 · e997e83
1 parent 9faa66a
commit e997e83
Showing 1 changed file with 6 additions and 7 deletions.
diff --git a/internal/config/config.go b/internal/config/config.go
@@ -423,15 +423,14 @@ func GetConfig() *Config {
 			config.KafkaUsername = *broker.Sasl.Username
 			config.KafkaPassword = *broker.Sasl.Password
 			config.KafkaSASLMechanism = *broker.Sasl.SaslMechanism
+		}
 
-			if broker.Cacert != nil {
-				caPath, err := cfg.KafkaCa(broker)
-				if err != nil {
-					panic("Kafka CA cert failed to write")
-				}
-
-				config.KafkaCA = caPath
+		if broker.Cacert != nil {
+			caPath, err := cfg.KafkaCa(broker)
+			if err != nil {
+				panic("Kafka CA cert failed to write")
 			}
+			config.KafkaCA = caPath
 		}
 
 		config.ConnectionDatabaseHost = cfg.Database.Hostname