Flink CDC中,有哪位大佬有flink 版本和cdc版本的适配统计啊?
Flink CDC 是 Flink 社区开发的 source 组件,可以直接从MySQL、PostgreSQL等数据库读取全量数据和增量变更数据。Flink CDC的版本与Flink的版本需要适配使用。例如,Flink CDC 2.3版本兼容了 Flink 1.13,1.14,1.15 和 1.16 四个大版本。
在实际应用中,你需要下载相应版本的Flink和CDC,并注意版本之间的兼容性。比如,在Flink 1.13.6上应用Flink CDC 2.2.0版本,或者在Apache Flink 1.14.3上使用mysql-cdc-connector-java-2.2.0。此外,Flink CDC的每个新版本都会带来一些新的特性和改进,如Flink CDC 2.0.0版本就带来了全量数据的并发读取、checkpoint、无锁读取等重大改进。
因此,使用哪个版本的Flink CDC,需要根据你使用的Flink版本以及具体需求来确定。
在使用 Flink CDC 进行数据同步时,需要确保 Flink CDC 版本与所使用的 CDC Connector 版本相适配。以下是一些常见的 Flink CDC 版本和 CDC Connector 版本之间的适配统计:
Flink CDC 1.12.x 适配的 CDC Connector 版本为:Debezium 1.3.x(支持的数据库包括 MySQL、PostgreSQL、SQL Server、Oracle 等)。
Flink CDC 1.11.x 适配的 CDC Connector 版本为:Debezium 1.2.x(支持的数据库包括 MySQL、PostgreSQL、SQL Server、Oracle 等)。
注意:
flink-connector-mysql-cdc
,而 Flink 1.11.x 使用的是 flink-connector-mysql-binlog
。Flink CDC 版本与 CDC(Change Data Capture)工具版本的适配情况可以大致总结如下:
1.x 系列:
2.x 系列:
2.4 系列:
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。