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

influxdata · Jan 5, 2024 · 12095b2 · 12095b2
1 parent d7a5bf6
commit 12095b2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/plugins/common/kafka/sasl.go b/plugins/common/kafka/sasl.go
@@ -34,13 +34,13 @@ func (k *SASLAuth) SetSASLConfig(cfg *sarama.Config) error {
 		return fmt.Errorf("getting username failed: %w", err)
 	}
 	cfg.Net.SASL.User = username.String()
-	username.Destroy()
+	defer username.Destroy()
 	password, err := k.SASLPassword.Get()
 	if err != nil {
 		return fmt.Errorf("getting password failed: %w", err)
 	}
 	cfg.Net.SASL.Password = password.String()
-	password.Destroy()
+	defer password.Destroy()
 
 	if k.SASLMechanism != "" {
 		cfg.Net.SASL.Mechanism = sarama.SASLMechanism(k.SASLMechanism)