Fix bug with earlier code by reading from the base config

Signed-off-by: Arun Yogesh 6723526+ArunYogesh@users.noreply.github.com Signed-off-by: Arun Yogesh <6723526+ArunYogesh@users.noreply.github.com>
kedacore · Feb 7, 2024 · 6834379 · 6834379
1 parent cca9652
commit 6834379
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pkg/scalers/kafka_scaler.go b/pkg/scalers/kafka_scaler.go
@@ -292,6 +292,10 @@ func parseKerberosParams(config *scalersconfig.ScalerConfig, meta *kafkaMetadata
 	}
 	meta.kerberosConfigPath = path
 
+	if config.AuthParams["serviceName"] != "" {
+		meta.serviceName = strings.TrimSpace(config.AuthParams["serviceName"])
+	}
+
 	meta.saslType = mode
 	return nil
 }