Skip usr/pwd validation if IAM mechanism is selected

open-telemetry · Jan 22, 2025 · 9ba8333 · 9ba8333
1 parent 64ac675
commit 9ba8333
Showing 1 changed file with 7 additions and 6 deletions.
diff --git a/exporter/kafkaexporter/config.go b/exporter/kafkaexporter/config.go
@@ -135,12 +135,13 @@ func validateSASLConfig(c *kafka.SASLConfig) error {
 		return nil
 	}
 
-	if c.Username == "" {
-		return fmt.Errorf("auth.sasl.username is required")
-	}
-
-	if c.Password == "" {
-		return fmt.Errorf("auth.sasl.password is required")
+	if c.Mechanism != "AWS_MSK_IAM" && c.Mechanism != "AWS_MSK_IAM_OAUTHBEARER" {
+		if c.Username == "" {
+			return fmt.Errorf("auth.sasl.username is required")
+		}
+		if c.Password == "" {
+			return fmt.Errorf("auth.sasl.password is required")
+		}
 	}
 
 	switch c.Mechanism {