flink cdc 异地数据同步

Flink CDC (Change Data Capture) 是一种用于实时流处理框架 Apache Flink 中的数据变更捕获技术，它主要用于在数据源之间高效地传输数据更新事件。当数据表发生增、删、改等变化时，CDC 系统会捕捉并记录这些变更，而不是全量复制所有数据。

在异地数据同步场景下，Flink CDC 的工作原理通常是这样的：

1. **数据监听**：Flink CDC 配置在源数据库上，实时监控数据表的变化，例如 MySQL 或 PostgreSQL 这样的支持事务日志（如 binlog 或 pg_log）的数据库。

2. **事件提取**：数据库的日志被读取并解析为一系列的事件，比如 INSERT, UPDATE, DELETE 等操作对应的事件。

3. **实时流转**：Flink 将这些变更事件作为数据流实时发送到目标系统，通常通过 Kafka 或其他消息队列进行中间缓存。

4. **目的地处理**：目标端的 Flink 任务接收到这些事件流后，对每个事件进行相应的处理，比如插入新行、更新旧行或删除记录，实现了两地的数据一致性。