Go Kafka 配置值

2024年 2月 6日 99.3k 0

go kafka - 配置值

问题内容

我正在使用 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 - 配置值的详细内容,更多请关注每日运维网(www.mryunwei.com)其它相关文章!

相关文章

JavaScript2024新功能:Object.groupBy、正则表达式v标志
PHP trim 函数对多字节字符的使用和限制
新函数 json_validate() 、randomizer 类扩展…20 个PHP 8.3 新特性全面解析
使用HTMX为WordPress增效:如何在不使用复杂框架的情况下增强平台功能
为React 19做准备:WordPress 6.6用户指南
如何删除WordPress中的所有评论

发布评论