當(dāng)嘗試使用golang連接到kafka消費(fèi)者（Centos中的kafka_2.11-2.0.0）時(shí)，出現(xiàn)以下錯(cuò)誤：[ 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)}實(shí)現(xiàn)kafka報(bào)錯(cuò)但是沒(méi)用。
1 回答
夢(mèng)里花落0921
TA貢獻(xiàn)1772條經(jīng)驗(yàn) 獲得超6個(gè)贊
當(dāng) librdkafka 庫(kù)在沒(méi)有 SSL 支持的情況下構(gòu)建時(shí)，將會(huì)出現(xiàn)此錯(cuò)誤。在 Centos 上，您需要在配置之前安裝 openssl-devel 軟件包。
- 1 回答
- 0 關(guān)注
- 326 瀏覽
添加回答
舉報(bào)
0/150
提交
取消