Ошибка: недопустимое значение sasl_ssl для свойства конфигурации security.protocol)

Question

При попытке подключиться к потребителю kafka ( kafka_2.11-2.0.0 в Centos) с помощью golang появляется ошибка ниже:

[ 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)
}

Реализована ошибка кафки, но бесполезно.

заранее спасибо

Answer 1

Когда библиотека librdkafka была собрана без поддержки SSL, возникнет эта ошибка. В Centos вам потребуется установить пакет openssl-devel перед настройкой. указать решение