Allow for sasl to be configured even if the CA cert is not explicitly…

… set for the kafka connection (#335)
RedHatInsights · Oct 2, 2023 · 2f882ed · 2f882ed
1 parent 03271a5
commit 2f882ed
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/internal/queue/queue.go b/internal/queue/queue.go
@@ -59,13 +59,13 @@ func Producer(in chan validators.ValidationMessage, config *ProducerConfig) {
 
 	if config.CA != "" {
 		_ = configMap.SetKey("ssl.ca.location", config.CA)
-		_ = configMap.SetKey("security.protocol", config.KafkaSecurityProtocol)
+	}
 
-		if config.SASLMechanism != "" {
-			_ = configMap.SetKey("sasl.mechanism", config.SASLMechanism)
-			_ = configMap.SetKey("sasl.username", config.Username)
-			_ = configMap.SetKey("sasl.password", config.Password)
-		}
+	if config.SASLMechanism != "" {
+		_ = configMap.SetKey("security.protocol", config.KafkaSecurityProtocol)
+		_ = configMap.SetKey("sasl.mechanism", config.SASLMechanism)
+		_ = configMap.SetKey("sasl.username", config.Username)
+		_ = configMap.SetKey("sasl.password", config.Password)
 	}
 
 	if config.Debug {