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.