大家早上好。我正在尝试Flink连接器Elasticsearch 5.2.1,但身份验证XPACK出现问题
发布于 2017-03-16 01:50:25
Flink目前不支持使用不同的传输客户端( 2017年3月,Flink 1.2)。
然而,我已经提交了一个JIRA来添加这个特性:FLINK-6065 Make TransportClient for ES5 pluggable
在Flink中实现这一点之前,我建议覆盖ElasticsearchSink,并使用调用PreBuiltXPackTransportClient的不同调用桥。
https://stackoverflow.com/questions/42807454
复制相似问题