嘗試使用 golang 連接到 kafka 消費(fèi)者( Centos 中的 kafka_2.11-2.0.0 )時,出現(xiàn)以下錯誤:[ 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)}實現(xiàn)了 kafka 錯誤但沒有用。
- 1 回答
- 0 關(guān)注
- 501 瀏覽
添加回答
舉報
0/150
提交
取消