Kafka Consu-6ren">
gpt4 book ai didi

go - 错误: Invalid value "sasl_ssl" for configuration property "security.protocol")

转载 作者:行者123 更新时间:2023-12-01 18:22:43 26 4
gpt4 key购买 nike

当尝试使用golang连接到kafka消费者(Centos中的kafka_2.11-2.0.0)时,出现以下错误:

[ 2019_12_12_12:45:05 ] ---->  Kafka Consumer Connection Error (kafka.Error=Invalid value "sasl_ssl" for configuration property "security.protocol")

代码:

consumer, err = kafka.NewConsumer(&kafka.ConfigMap{
"bootstrap.servers": "example.window.net:9093",
"group.id": "my-Group",
"auto.offset.reset": "earliest",
"sasl.mechanisms": "PLAIN",
"security.protocol": "sasl_ssl",
"sasl.username": "test",
"sasl.password": "test",
})
if err != nil {
fmt.Sprintf("Kafka Consumer Connection Error", err)
}

已实现kafka error但没有用。

提前致谢

最佳答案

当 librdkafka 库在没有 SSL 支持的情况下构建时,将会出现此错误。在 Centos 上,您需要在配置之前安装 openssl-devel 软件包。引用solution

关于go - 错误: Invalid value "sasl_ssl" for configuration property "security.protocol"),我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/59307116/

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com