elasticsearch - Flink Xpack ElasticSearch 5 ElasticsearchSecurityException缺少身份验证

Question

大家，早安。我正在尝试Flink连接器Elasticsearch 5.2.1，并且认证XPACK出现问题

Answer 1

Flink当前不支持使用其他传输客户端(2017年3月，Flink 1.2)。

但是，我已提交JIRA以添加功能:FLINK-6065Make TransportClient for ES5 pluggable

在将此实现到Flink中之前，我建议重写ElasticsearchSink并使用另一个调用PreBuiltXPackTransportClient的调用桥。