in kafka/configfile.go [146:157]
func (s *saslConfigProperties) finalize() error {
switch s.Mechanism {
case "":
if s.Username != "" {
s.Mechanism = "PLAIN"
}
case "PLAIN", "AWS_MSK_IAM":
default:
return fmt.Errorf("kafka: unsupported SASL mechanism %q", s.Mechanism)
}
return nil
}