TiCDC 数据同步能力详解

TiCDC (TiDB Change Data Capture) 是 TiDB 生态中用于​​实时数据同步​​的核心组件。本文详细解释 TiCDC 的数据同步能力。

工作原理​

• TiCDC 监听 TiKV 的变更日志 (Raft Log)，将行数据的增删改操作转换为下游兼容的 SQL 语句，并不基于上游的 SQL 获取数据变更。详情请参考 TiCDC 处理数据变更的实现原理。

• TiCDC 生成与 SQL 语义等效的逻辑操作（如 INSERT、UPDATE、DELETE），而非逐条还原上游执行的原始 SQL 语句。详情请参考 TiCDC 处理数据变更的实现原理。

• TiCDC 提供事务最终一致性的保证。开启 redo log 后，TiCDC 可以保证容灾场景下的最终一致性；开启 Syncpoint 后，TiCDC 提供一致性快照读和数据一致性校验。

支持的下游

TiCDC 支持同步数据到多类下游，包括：

• TiDB 及兼容 MySQL 协议的数据库
• Apache Kafka
• Message Queue (MQ) 类的下游，如 Pulsar
• 存储服务（Amazon S3、GCS、Azure Blob Storage 和 NFS）
• 通过 Confluent Cloud 同步至 Snowflake、ksqlDB、SQL Server
• 使用 Apache Flink 消费同步至 Kafka 的数据

数据同步范围

TiCDC 对上游数据变更的支持范围如下：

• 支持：

  • DDL 和 DML 语句（非系统表）。
  • 索引操作 (ADD INDEX, CREATE INDEX)：为了减少对 Changefeed 同步延迟的影响，当下游为 TiDB 时，TiCDC 会异步执行创建和添加索引的 DDL 操作。
  • 外键约束 DDL 语句 (ADD FOREIGN KEY)：TiCDC 不会同步上游系统变量的设置，需要在下游手动设置 foreign_key_checks 来决定是否开启下游的外键约束检查。另外，TiCDC 在向下游写入数据时，自动启用会话级别的设置 SET SESSION foreign_key_checks = OFF;。因此，即使下游开启了全局外键检查，TiCDC 写入的数据也不会触发外键约束验证。

• 不支持：

  • 系统表（如 mysql.* 和 information_schema.*）的 DDL 和 DML 语句。
  • 临时表的 DDL 和 DML 语句。
  • DQL (Data Query Language) 语句 和 DCL (Data Control Language) 语句。

使用限制

• TiCDC 对一些场景暂不支持，详见暂不支持的场景。

• TiCDC 只检查上游数据变更的完整性，不检查数据变更是否符合上游或下游的约束。如果遇到不满足下游约束的数据变更，TiCDC 会在写入下游时报错。

  例如：当通过 changefeed 配置了过滤所有 DDL 事件后，如果上游执行 DROP COLUMN 操作后继续写入涉及该列的 INSERT 语句，TiCDC 同步这些 DML 变更到下游时，会因下游表结构不同而导致数据写入失败。