在我的Flink工作中,我正在尝试使用 Elasticsearch7 连接器。当使用 elasticsearch7sinkbuilder 时,我找不到通过SSL通信的方法?
另外,还有一个弃用的类 elasticsearchSink.builder 它具有 RESTCLIENTFACTORY ,我可以用来设置HTTPS连接,但是由于此类的弃用,因此想知道是否可以使用 elasticsearch7sinkbuilder 。
另外,由于 Elasticsearch 8 还没有连接器,是否可以将上述任何客户端与Elastic 8一起使用?
注意:以前,它曾经是Flink Doc中的弹性连接器兼容性矩阵,但我在DOC的持久版本中找不到它。
In my flink job, I am trying to use elasticsearch7 connector. I could not find a way to communicate over SSL when using Elasticsearch7SinkBuilder Am I missing something?
Also there is an deprecated class ElasticsearchSink.Builder where it has RestClientFactory which I can use to setup https connection but since this class is deprecated thus wondering if same is possible with Elasticsearch7SinkBuilder.
Also since there is no connector for elasticsearch 8 yet, Is it possible to use any of the above client with elastic 8?
Note: Earlier it used to be elastic connector compatibility matrix in Flink doc but I could not find it any more in lasted version of doc.
发布评论
评论(1)
当前不支持与Elasticsearch7的SSL连接,并在
。您不能使用ES7连接器连接到ES8群集。
SSL connections to Elasticsearch7 are currently not supported and are tracked under https://issues.apache.org/jira/browse/FLINK-27054
An Elasticsearch8 connector is being tracked under https://issues.apache.org/jira/browse/FLINK-26088. You can't use the ES7 connector to connect to an ES8 cluster.