Flink Xpack ElasticSearch 5 ElasticsearchSecurityException 缺少认证

Question

大家早上好。我正在尝试使用 Flink 连接器 Elasticsearch 5.2.1，我在身份验证 XPACK

方面遇到问题

Answer 1

Flink 目前不支持使用不同的传输客户端（2017 年 3 月，Flink 1.2）。

但是，我已经提交了一个 JIRA 来添加功能：FLINK-6065 使 ES5 的 TransportClient 可插入

在 Flink 实现之前，我建议覆盖 ElasticsearchSink 并使用不同的调用桥调用 PreBuiltXPackTransportClient。