flink xpack elasticsearch 5 elasticsearchsecurityexception缺少身份验证

0s0u357o  于 2021-06-25  发布在  Flink
关注(0)|答案(1)|浏览(301)

大家早上好。我正在尝试flink connector elasticsearch 5.2.1,我的身份验证xpack有问题

wvyml7n5

wvyml7n51#

flink目前不支持使用不同的传输客户端(2017年3月,flink 1.2)。
不过,我已经提交了一个jira来添加这个特性:flink-6065使transportclient for es5可插拔
在flink中实现之前,我建议重写 ElasticsearchSink 使用不同的呼叫桥呼叫 PreBuiltXPackTransportClient .

相关问题