请教一个小白的问题,我看官网上flink cdc 2.2.* 版本 支持 flink 1.13., 1.14. ,1.15 及以后的flink版本不能用cdc吗?
新版本一般会兼容旧版本,即使不兼容也会在中间的版本过渡,给用户缓冲期。所以高版本基本都会对低版本进行支持。
一般下个版本是可以上个版本的功能,以及修复一些已知的bug,所以这个问题是肯定可以使用CDC的。
可以使用的呀,新版本一般都是为了上新的功能,但是之前的功能肯定也是正常使用的,如果你不追求最新版的功能,大可不必担心。
Flink CDC 2.2 版本正式发布,2.2 版本新增 OceanBase,PolarDB-X,SqlServer,TiDB 四种数据源接入,均支持全量和增量一体化同步。至此,Flink CDC 已支持 12 种数据源。
Flink CDC 兼容 Flink 1.13 和 Flink 1.14 两个大版本,2.2 版本的所有 Connector 都支持跑在 Flink 1.13.* 或 Flink 1.14.* 的集群上。
Flink CDC 2.2 版本新增 OceanBase CDC,SqlServer CDC,TiDB CDC 三个连接器,而 PolarDB-X 的支持则是通过对 MySQL CDC 连接器进行兼容适配实现。
2.2 版本之前,Flink CDC 连接器都只对应一个 Flink 大版本,Flink CDC 2.2 版本兼容 Flink 1.13.* 和 Flink 1.14.* 两个大版本,这意味 2.2 版本的所有 Connector 既可以跑在 Flink 1.13.* 集群上,又可以跑在 Flink 1.14.* 的集群上。通过提供兼容多版本的能力,让 Flink CDC 在提供 1.14 支持的同时,还极大地降低用户的 connector 管理成本。
MySQL CDC 支持 MySQL 5.6 从 2.2 版本开始, MySQL CDC 支持了 MySQL 5.6 版本,满足低版本的 MySQL 用户需求。
Flink目前最新版本已经更新到1.15.2版本,flink-cdc的release版本目前最新版本是2.2.1。flink-cdc官网的版本信息显示,2.2.*版本是支持flink1.13.及1.14.,并没有支持flink1.15.*的release版本,需要自己编译flink-cdc源码,在master分支上修改Flink版本。
在flink-connector-mysql-cdc模块的pom文件中,有一个flink-table-planner的依赖,这个依赖的 artifactId 不用更改,这个依赖在1.15版本中,artifactId 也是带 scala版本后缀的。
对flink版本的修改就完成,看flink-cdc的代码是否兼容flink-1.15.2。
换版本一定会出点什么意外的。
最新的Flink cdc 2.3.0 新增了 DB2 CDC 连接器,兼容了Flink 1.13 & 1.14 & 1.15 & 1.16 四个版本。
都可以用,但是配置变了,要从官网上找相关的配置,这三版应该没太大变化,但是最新版肯定是没问题的,建议用最新版
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。