當嘗試使用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報錯但是沒用。
1 回答
夢里花落0921
TA貢獻1772條經驗 獲得超6個贊
當 librdkafka 庫在沒有 SSL 支持的情況下構建時，將會出現此錯誤。在 Centos 上，您需要在配置之前安裝 openssl-devel 軟件包。
- 1 回答
- 0 關注
- 321 瀏覽
添加回答
舉報
0/150
提交
取消