Flink Xpack Elasticsearch 5 ElasticsearchSecurityException缺少

Question

祝大家大家。我正在尝试翻转连接器Elasticsearch 5.2.1，并且身份验证XPACK

Answer 1

目前使用其他运输客户端（2017年3月，弗林克1.2）。

但是，我已经提交了JIRA来添加该功能：Flink-6065使ES5插入运输量

直到将其实现为flink，我建议覆盖ElasticsearchSink并使用其他呼叫桥调用PreBuiltXPackTransportClient。