具有SSL的Flink弹性搜索连接器7

Question

在我的flink工作中，我尝试使用elasticsearch7连接器。在使用Elasticsearch7SinkBuilder时，我找不到一种通过SSL进行通信的方法，是不是遗漏了什么？

此外，还有一个不推荐的类ElasticsearchSink.Builder，它有RestClientFactory，我可以使用它来设置https连接，但是由于这个类是不推荐的，所以想知道Elasticsearch7SinkBuilder.是否可以使用这个类。

另外，由于elasticsearch 8还没有连接器，是否可以使用弹性8的上述客户端？

注意:以前它是Flink doc中的弹性连接器兼容性矩阵，但是我无法再找到它的持续版本doc。

Answer 1

目前不支持到Elasticsearch7的SSL连接，并且在https://issues.apache.org/jira/browse/FLINK-27054下进行跟踪。

Elasticsearch8连接器正在https://issues.apache.org/jira/browse/FLINK-26088下进行跟踪。不能使用ES7连接器连接到ES8集群。