Flink Xpack ElasticSearch 5 ElasticsearchSecurityException 缺少身份验证 [英] Flink Xpack ElasticSearch 5 ElasticsearchSecurityException missing autentication

问题描述

大家早上好.我正在尝试 Flink 连接器 Elasticsearch 5.2.1，但我在验证 XPACK 时遇到问题

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

推荐答案

Flink 目前不支持使用不同的传输客户端(2017 年 3 月，Flink 1.2).

Using a different transport clients is currently (March 2017, Flink 1.2) not supported in Flink.

但是，我已提交 JIRA 以添加该功能:FLINK-6065使 ES5 的 TransportClient 可插入

However, I've filed a JIRA to add the feature: FLINK-6065 Make TransportClient for ES5 pluggable

在 Flink 中实现此功能之前，我建议覆盖 ElasticsearchSink 并使用不同的调用桥来调用 PreBuiltXPackTransportClient.

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屋！