3

尝试使用 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 错误但没有用。

提前致谢

4

1 回答 1

3

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

于 2019-12-13T09:55:36.203 回答