错误：配置属性“security.protocol”的值“sasl_ssl”无效）

Question

当尝试使用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报错但是没用。

Answer 1

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