Elasticsearch 8.x Flink Connector 实用方案及业内使用情况咨询
Flink Elasticsearch 8.x 连接器使用方案及用户实践疑问
我尝试使用Elasticsearch 8.x Connector,根据Apache Flink JIRA的FLINK-26088工单,该连接器数月前已开发完成,但目前Maven仓库中找不到elasticsearch8相关构件,推测尚未正式发布,可能是因为绑定到Flink 3.1版本待发。
我梳理了几种可行的使用方案,按优先级排序如下:
- 直接从Maven引用:这是最优方案,但前提是相关构件在Maven可获取,目前该版本尚未正式发布,暂时无法使用。
- 兼容性模式临时方案:将elasticsearch7连接器底层的Rest High Level Client升级至3.17.x,利用Elasticsearch 7.x与8.x的互操作兼容性模式来适配。不过当前连接器使用的是3.10.x版本,跨7个小版本升级存在一定风险。
- 使用第三方连接器构件:发现阿里云提供了类似构件
com.alibaba.ververica:flink-connector-elasticsearch8,但更倾向于使用官方版本。 - Fork连接器代码自行编译:这是最不理想的方案,即Fork已开发完成的ES 8.x连接器代码,在本地项目中引用,直到官方正式版本发布。
想了解目前其他用户是如何使用该连接器的?
内容的提问来源于stack exchange,提问作者Rion Williams
相关产品推荐
相关产品推荐

