大家早上好。我正在尝试flink connector elasticsearch 5.2.1,我的身份验证xpack有问题
wvyml7n51#
flink目前不支持使用不同的传输客户端(2017年3月,flink 1.2)。不过,我已经提交了一个jira来添加这个特性:flink-6065使transportclient for es5可插拔在flink中实现之前,我建议重写 ElasticsearchSink 使用不同的呼叫桥呼叫 PreBuiltXPackTransportClient .
ElasticsearchSink
PreBuiltXPackTransportClient
1条答案
按热度按时间wvyml7n51#
flink目前不支持使用不同的传输客户端(2017年3月,flink 1.2)。
不过,我已经提交了一个jira来添加这个特性:flink-6065使transportclient for es5可插拔
在flink中实现之前,我建议重写
ElasticsearchSink
使用不同的呼叫桥呼叫PreBuiltXPackTransportClient
.