大家，早安。我正在尝试 Flink 连接器 Elasticsearch 5.2.1，但我遇到了身份验证 XPACK 问题
问问题
322 次
1 回答
0
Flink 目前（2017 年 3 月，Flink 1.2）不支持使用不同的传输客户端。
但是，我已经提交了一个 JIRA 来添加该功能：FLINK-6065 Make TransportClient for ES5 pluggable
在这被实现到 Flink 之前，我建议覆盖ElasticsearchSink并使用不同的调用桥来调用PreBuiltXPackTransportClient.
于 2017-03-15T17:50:24.627 回答