在我的flink作业中,我正在尝试使用elasticsearch7连接器。当使用Elasticsearch7SinkBuilder时,我找不到通过SSL进行通信的方法。我是否遗漏了什么?
此外,还有一个已弃用的类ElasticsearchSink.Builder,其中包含RestClientFactory,我可以使用它来设置https连接,但由于此类已弃用,因此不知道是否可以使用Elasticsearch7SinkBuilder进行相同操作。
此外,由于elasticsearch 8还没有连接器,是否可以使用任何上述客户端与弹性8?
注:早些时候,它曾经是弹性连接器兼容性矩阵在Flink文件,但我无法找到它在任何更上一个版本的文件。
1条答案
按热度按时间cvxl0en21#
当前不支持与Elasticsearch7的SSL连接,并在https://issues.apache.org/jira/browse/FLINK-27054下进行跟踪
正在https://issues.apache.org/jira/browse/FLINK-26088下跟踪Elasticsearch8连接器。您不能使用ES7连接器连接到ES8群集。