与flink 1.16版本适配的Elasticsearch 连接器
时间: 2023-12-20 15:45:28 浏览: 213
Flink 1.16 版本官方支持的 Elasticsearch 连接器版本是 flink-sql-connector-elasticsearch7-1.12.0.jar。你可以在 Maven 仓库中找到它的下载链接:
https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch7/1.12.0/flink-sql-connector-elasticsearch7-1.12.0.jar
如果你需要其他 Flink 版本的 Elasticsearch 连接器,可以在 Maven 仓库中查找特定版本的连接器。在 Maven 仓库中,连接器的版本号通常包含了 Flink 的版本号信息,例如:
- Flink 1.13 版本对应的 Elasticsearch 连接器版本:flink-sql-connector-elasticsearch7-1.13.0.jar
- Flink 1.14 版本对应的 Elasticsearch 连接器版本:flink-sql-connector-elasticsearch7-1.14.0.jar
- Flink 1.15 版本对应的 Elasticsearch 连接器版本:flink-sql-connector-elasticsearch7-1.15.0.jar
注意,在使用不同版本的 Elasticsearch 连接器时,你需要根据连接器的 API 文档进行调整。
相关问题
https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch7/3.0.1-1.17/flink-sql-connector-elasticsearch7-3.0.1-1.17.jar 与flink 1.16版本适配吗
根据 Flink 官方文档,Flink 1.16 版本的官方依赖包中并没有包含 flink-sql-connector-elasticsearch7-3.0.1-1.17.jar 这个版本的 Elasticsearch 连接器。因此,这个版本的连接器可能不适用于 Flink 1.16 版本。
如果你想要使用 Elasticsearch 连接器,可以尝试使用 Flink 官方文档中列出的支持版本,或者自行调整连接器的代码以适配 Flink 1.16 版本。
flink-sql-connector-mysql-cdc-1.12.2 支持flink1.16版本吗
flink-sql-connector-mysql-cdc-1.12.2 不支持 Flink 1.16 版本,它只支持 Flink 1.12.x 和 1.13.x 版本。如果您需要在 Flink 1.16 版本中使用 MySQL CDC,可以考虑使用官方提供的 flink-sql-connector-mysql,该 connector 支持 Flink 1.11.x 到 1.16.x 版本,并且可以通过配置开启 MySQL CDC 功能。
阅读全文