开源工具 · 大数据运维
Apache Flink CDC
以 MySQL 单表为试点,核对 CDC 版本、增量快照与日志衔接、Schema 事件及目标提交,通过有限样本与隔离恢复验证同步边界。
Overview
适用范围
采用 Flink CDC 3.4.x、Flink 1.20 与 MySQL 8.0.x,优先选择有稳定主键的 InnoDB 单表。CDC 3.4.x 官方支持 Flink 1.19/1.20;Pipeline 与 SQL source 的结构演进能力分开核验。
验收范围
本流程先进行只读诊断,再在独立目标演练一次快照期间变化、结构变化和失败恢复。预计时间仅覆盖有限试点,不包含大表全量初始化。文档及参考图均待环境验证,不提供在线体验。
配套知识
官方参考
集成状态
本站按 L1 资料收录,未声明最新安装版本;不在线执行全量同步、DDL 或生产恢复。MySQL JDBC 驱动及 sink 制品需按实际部署补齐。