Skip to content

Commit

Permalink
Fix bug with earlier code by reading from the base config
Browse files Browse the repository at this point in the history
Signed-off-by: Arun Yogesh 6723526+ArunYogesh@users.noreply.github.com
Signed-off-by: Arun Yogesh <6723526+ArunYogesh@users.noreply.github.com>
  • Loading branch information
ArunYogesh committed Feb 7, 2024
1 parent cca9652 commit 6834379
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions pkg/scalers/kafka_scaler.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
}
Expand Down

0 comments on commit 6834379

Please sign in to comment.