当尝试使用golang连接到kafka消费者(centos中的kafka_.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错误,但没有用。
提前谢谢
1条答案
按热度按时间k2fxgqgv1#
当librdkafka库在没有ssl支持的情况下构建时,这个错误就会出现。在centos上,您需要在配置之前安装openssl-devel包。参考解决方案