diff --git a/pkg/scalers/kafka_scaler.go b/pkg/scalers/kafka_scaler.go index 3b7fef44879..b0e3df08f6f 100644 --- 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 }