我正在使用 go-kafka (https://pkg.go.dev/github.com/confluenceinc/confluence-kafka-go/kafka#configmap.get)，并且在使用 configmap 的 get 方法时遇到问题。
文档说 get 需要一个键和一个 defval（类型为 configvalue），但我不知道如何创建一个 configvalue 来传入。
这是我尝试过的：
configfile := os.args[1]
conf := readconfig(configfile)
x := conf["sasl.password"]
fmt.printf(conf.get("sasl.password", x))configFile := os.Args[1]
conf := ReadConfig(configFile)
x := kafka.ConfigValue("Test")
fmt.Printf(conf.Get("sasl.password", x))但是每次我都会遇到同样的错误：
不能使用 'conf.get("sasl.password", x)' (type (configvalue, error)) 作为类型 (string, any) 或 string
我哪里出错了？
就您使用 configmap.get 而言，您本身没有做任何错误。
您看到的错误是由于您使用 fmt.printf 造成的。
立即错误是因为 get() 返回一个值和一个错误 ((configvalue, error))，您试图将其直接传递到 printf() ，它需要一个包含格式说明符和变量列表的字符串要替换为这些格式规范的任何值。
您首先需要获取 configmap 值并测试是否有错误：
v, err := conf.get("sasl.password", x)
if err != nil {
// handle/return the error
}
然后，如果 err 为 nil，您可以使用 %s 规范将值输出到 printf 并传入返回值：
if err == nil {
fmt.Printf("%s", v)
}
以上就是Go Kafka - 配置值的详细内容，更多请关注php中文网其它相关文章！
Kafka Eagle是一款结合了目前大数据Kafka监控工具的特点，重新研发的一块开源免费的Kafka集群优秀的监控工具。它可以非常方便的监控生产环境中的offset、lag变化、partition分布、owner等，有需要的小伙伴快来保存下载体验吧！
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号
971
收藏
