CL-Softwares
/
telegraf
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(common.kafka): Correctly set gssapi username/password (#14522)

This commit is contained in:
Joshua Powers 2024-01-05 02:57:52 -07:00 committed by GitHub
parent d7a5bf6d70
commit 12095b2828
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
plugins/common/kafka/sasl.go
View File

@ -34,13 +34,13 @@ func (k *SASLAuth) SetSASLConfig(cfg *sarama.Config) error {
return fmt.Errorf("getting username failed: %w", err) return fmt.Errorf("getting username failed: %w", err)
} }
cfg.Net.SASL.User = username.String() cfg.Net.SASL.User = username.String()
username.Destroy() defer username.Destroy()
password, err := k.SASLPassword.Get() password, err := k.SASLPassword.Get()
if err != nil { if err != nil {
return fmt.Errorf("getting password failed: %w", err) return fmt.Errorf("getting password failed: %w", err)
} }
cfg.Net.SASL.Password = password.String() cfg.Net.SASL.Password = password.String()
password.Destroy() defer password.Destroy()
if k.SASLMechanism != "" { if k.SASLMechanism != "" {
cfg.Net.SASL.Mechanism = sarama.SASLMechanism(k.SASLMechanism) cfg.Net.SASL.Mechanism = sarama.SASLMechanism(k.SASLMechanism)