Flink Xpack ElasticSearch 5 ElasticsearchSecurityException失去自动化 [英] Flink Xpack ElasticSearch 5 ElasticsearchSecurityException missing autentication

问题描述

大家好。我试图Flink连接器Elasticsearch 5.2.1和我有验证XPACK的问题

解决方案

目前使用不同的传输客户端（2017年3月，Flink 1.2）不支持Flink。

但是，我已经提交了一个JIRA来添加功能： FLINK-6065
Make TransportClient for ES5 pluggable

直到这已被实现到Flink中，我建议覆盖 ElasticsearchSink ，并使用不同的调用桥调用 PreBuiltXPackTransportClient 。

Goodmorning everyone. I am trying to Flink connector Elasticsearch 5.2.1 and I have problems with the authentication XPACK

解决方案

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.

这篇关于Flink Xpack ElasticSearch 5 ElasticsearchSecurityException失去自动化的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！