我收到这些错误消息
由于以下错误而重新更新元数据：代理在发出请求后立即关闭了连接，这在需要SASL但未提供时发生：是否缺少SASL？从代理读取时出错，在0次成功响应后终止连接（是否缺少SASL？）
我正在尝试添加身份验证。我的代码是：

auth := scram.Auth{
        User: "kafka_user",
        Pass: "kafka_pass",
    }
    
    cl, err := kgo.NewClient(
        kgo.SeedBrokers(seeds...),
        kgo.DialTLSConfig(tlsConfig),
        kgo.SASL(auth.AsSha512Mechanism()),
        kgo.ConsumerGroup(consumerGroupId),
        kgo.ConsumeTopics(topics...),
        kgo.WithLogger(kzap.New(logger.GetLogger())),
    )

字符串
身份验证的要求是：

• SSL：错误
• 安全协议：SASL_PLAINTETEXT
• SASL机制：SCRAM-SHA-512
• 用户名：<>
• 密码：<>

我尝试了文档中的所有方法。甚至在Google Bard和Bing AI的帮助下，尝试了所有可能的解决方案，但这个问题仍然存在。