登录
首页 >  Golang >  Go问答

SASL协议问题：Franz-go kafka身份验证错误

来源：stackoverflow

时间：2024-02-22 10:00:24 349浏览 收藏

你在学习Golang相关的知识吗？本文《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?)"

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

1
2
3
4
5
6
7
8
9
10
11
12
13
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 并尝试了所有可能的解决方案，这个问题仍然存在。


正确答案


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

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《SASL协议问题：Franz-go kafka身份验证错误》文章吧，也可关注golang学习网公众号了解相关技术文章。

声明：本文转载于：stackoverflow 如有侵犯，请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>