flink cdc中,什么版本的flink和 3.0的cdc比较兼容?
Apache Flink CDC 3.0支持全量数据同步,并且支持定期或按需触发全量数据的snapshot。在Flink的整体架构中,checkpoint是Flink流处理的核心特性之一,它可以确保在故障恢复时系统的状态一致性。对于Flink CDC而言,checkpoint的作用同样重要,特别是在处理数据库变更日志时,能够将数据源的位置信息(如MySQL的binlog位置)和中间计算状态一起持久化,以备故障恢复后继续从正确的点开始消费数据。
关于Flink版本与Flink CDC 3.0的兼容性问题,通常Flink CDC 3.0版本会与Flink的某个主版本兼容。例如,Flink CDC 3.0可能对应的是Flink 1.12.x或更高版本
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。