介绍

Apache Flink CDC 3.0 是 Flink CDC 的新版本，它对之前的版本做了很多改进，包括性能、稳定性和易用性等方面。

特性

1. 新的 CDC 连接器

Flink CDC 3.0 提供了对 MySQL、PostgreSQL、Oracle 和 SQL Server 等主流数据库的 CDC 支持。这些连接器使用数据库的原生 CDC 接口，可以高效地捕获数据库中的数据变更。

2. 更快的读取速度

Flink CDC 3.0 支持并行读取，可以显著提高读取速度。并行读取是指将数据读取任务分解成多个小任务，然后由多个线程同时执行这些任务。这样可以大大提高数据读取的吞吐量。

3. 更高的可靠性

Flink CDC 3.0 支持端到端检查点，可以保证数据的一致性和准确性。端到端检查点是指将数据读取任务的状态和数据都保存到检查点中。如果发生故障，可以从检查点恢复数据读取任务，而不会丢失任何数据。

4. 更低的延迟

Flink CDC 3.0 支持增量读取，可以减少延迟。增量读取是指只读取上次读取之后的数据变更。这样可以减少需要读取的数据量，从而降低延迟。

5. 更简单的使用

Flink CDC 3.0 提供了统一的 API，可以轻松地集成到 Flink 中。统一的 API是指所有数据库的 CDC 连接器都使用相同的 API。这样可以简化开发人员的使用，并降低学习成本。

6. 高可用

Flink CDC 3.0 支持高可用性，可以保证在发生故障时数据仍然能够被读取。高可用性是指在发生故障时，Flink CDC 3.0 能够自动将数据读取任务转移到其他节点继续执行。这样可以保证数据读取任务不会中断，并且不会丢失任何数据。

7. 可扩展性

Flink CDC 3.0 支持可扩展性，可以轻松地扩展到更大的数据量。可扩展性是指 Flink CDC 3.0 能够通过增加节点来提高数据读取的吞吐量。这样可以满足不断增长的数据量需求。

8. 安全性

Flink CDC 3.0 支持安全性，可以保证数据的安全传输。安全性是指 Flink CDC 3.0 可以使用 SSL 加密来保护数据传输。这样可以防止数据在传输过程中被窃取。

1. 数据同步：可以将数据从源数据库同步到目标数据库。

2. 数据分析：可以将数据从源数据库同步到数据分析平台，以便进行数据分析。

3. 数据集成：可以将数据从源数据库同步到其他系统，以便进行数据集成。

4. 数据备份：可以将数据从源数据库同步到备份系统，以便进行数据备份。

https://mp.weixin.qq.com/s/dCJMdCRH9LO6vB2GuRM_0Q