SASL 是否丢失了？Franz-go kafka 身份验证困扰

我收到这些错误消息

"re-updating metadata due to err: broker closed the connection immediately after a request was issued, which happens when SASL is required but not provided: is SASL missing?"
"read from broker errored, killing connection after 0 successful responses (is SASL missing?)"

我正在尝试添加身份验证。 我的代码是：

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_PLAINTEXT
• SASL机制：SCRAM-SHA-512
• 用户名：<>
• 密码：<>

我尝试了文档中的所有内容。即使借助 google bard 和 Bing AI 并尝试了所有可能的解决方案，这个问题仍然存在。

正确答案

包裹没有问题。代码未部署，因此问题不在于代码，而在于部署。