SASL handshake failed

[j285627868]

hi guys，

When I connect to the Kafka server, I receive the following error message:

could not successfully authenticate to 192.107.0.1:9200 with SASL: SASL handshake failed: [34] Illegal SASL State: the request is not valid given the current SASL state

The code for the connection is as follows:

func NewClient() *kafka.Reader {
	conf := config.Cfg.Kafka
	groupTopics := strings.Join(conf.Topic, "-")
	consumerGroup := fmt.Sprintf("%s_xxx_%s_%d", groupTopics, "group", conf.Node)
	mechanism, errM := scram.Mechanism(scram.SHA256, conf.Username, conf.Password)
	if errM != nil {
		panic(errM)
	}
	return kafka.NewReader(kafka.ReaderConfig{
		Brokers:     conf.Addrs,
		GroupID:     consumerGroup,
		GroupTopics: conf.Topic,
		MaxBytes:    10e6, // 10MB
		Dialer: &kafka.Dialer{
			Timeout:       10 * time.Second,
			DualStack:     true,
			SASLMechanism: mechanism,
		},
	})
}
func (k *KAFKA) Run() error {
	var err error
	var msg kafka.Message
	ctx := context.Background()
	for {
		msg, err = k.Client.FetchMessage(ctx)
		if err != nil {
                }
}

May I ask where the problem lies? thank you.

[petedannemann]

This error is usually thrown when SASL is not configured on the broker correctly. Can you check your broker SASL configuration and broker logs?