Goodmorning everyone. I am trying to Flink connector Elasticsearch 5.2.1 and I have problems with the authentication XPACK
可以将文章内容翻译成中文,广告屏蔽插件可能会导致该功能失效(如失效，请关闭广告屏蔽插件后再试):
问题:
回答1:
Using a different transport clients is currently (March 2017, Flink 1.2) not supported in Flink.
However, I've filed a JIRA to add the feature: FLINK-6065 Make TransportClient for ES5 pluggable
Until this has been implemented into Flink, I recommend overriding the ElasticsearchSink and using a different call bridge calling the PreBuiltXPackTransportClient.
