- Home
- Change Data Capture Software
- Apache Flink CDC
Apache Flink CDC
What it is
Apache Flink CDC is a free, open-source distributed data integration tool for real-time and batch data, built on Apache Flink. It supports complete database synchronization, sharded-table synchronization, schema evolution and data transformation. Its YAML Pipeline API lets users declare sources, sinks, routing, transformations and schema-evolution rules. SQL and DataStream APIs support change-data-capture sources and custom Flink streaming applications. Listed pipeline connectors include Doris, Elasticsearch, Fluss, Hudi, Iceberg, Kafka, MaxCompute, MySQL, OceanBase, Oracle, Paimon, PostgreSQL and StarRocks. Source connectors also cover SQL Server, MongoDB, TiDB, Db2 and Vitess. Flink CDC 3.6 is listed as compatible with Flink 1.20 and 2.2, while version 3.6.0 requires JDK 11 or later. Deployment is self-hosted: download Flink CDC and connector JARs, then run them with Apache Flink. Supported environments include Linux, macOS, Windows and self-hosted systems.
For and against
For
- Free under the Apache 2.0 License
- Supports full and sharded synchronization
- Provides YAML, SQL and DataStream APIs
- Includes schema evolution and transformations
- Offers many listed database and pipeline connectors
Against
- Self-hosted deployment is required
- Flink CDC 3.6.0 requires JDK 11 or later
- Running it requires an Apache Flink deployment
- Support is directed to mailing lists and JIRA
The verdict
Apache Flink CDC provides declarative and programmatic CDC pipelines with broad connector coverage. Its Apache license and platform support suit organizations prepared to run and maintain Flink-based infrastructure.
Who it suits
It suits teams needing self-hosted change-data capture and synchronization across databases and streaming destinations. Users should be prepared to operate Apache Flink and meet the JDK 11-or-later requirement for version 3.6.0.
Plans and prices
Apache Flink CDC
Apache License 2.0 · released JARs and connectors
Read 30 Sep 2026 · github.com
On the record
- Deployment
- The documentation describes downloading and extracting Flink CDC and connector JARs, then running it with an Apache Flink deployment.nightlies.apache.org · read 30 Sep 2026
- Flink compatibility
- The repository lists Flink CDC 3.6 as compatible with Flink 1.20 and 2.2.github.com · read 30 Sep 2026
- Integrations
- Pipeline connectors listed include Doris, Elasticsearch, Fluss, Hudi, Iceberg, Kafka, MaxCompute, MySQL, OceanBase, Oracle, Paimon, PostgreSQL, and StarRocks.github.com · read 30 Sep 2026
- License
- The repository states that Flink CDC is distributed under the Apache 2.0 License.github.com · read 30 Sep 2026
- Other APIs
- It also provides SQL and DataStream APIs for defining CDC sources and custom Flink streaming applications.github.com · read 30 Sep 2026
- Pipeline API
- Its YAML Pipeline API lets users define sources, sinks, routing, transformations, and schema evolution rules declaratively.github.com · read 30 Sep 2026
- Purpose
- Flink CDC is a distributed data integration tool for real-time and batch data, built on Apache Flink.github.com · read 30 Sep 2026
- Runtime requirement
- The documentation says Flink CDC 3.6.0 is built on JDK 11 and requires JDK 11 or later.nightlies.apache.org · read 30 Sep 2026
- Schema and transformation
- It supports schema evolution and data transformation.github.com · read 30 Sep 2026
- Security
- The repository links to a security policy, but its contents were not available in the opened page.github.com · read 30 Sep 2026
- Source databases
- SQL and DataStream source connectors listed include MySQL, PostgreSQL, Oracle, SQL Server, MongoDB, OceanBase, TiDB, Db2, and Vitess.github.com · read 30 Sep 2026
- Support
- The project directs users to its user mailing list for support and questions, and to Flink JIRA for problems.github.com · read 30 Sep 2026
- Synchronization
- It supports full database synchronization and sharded table synchronization.github.com · read 30 Sep 2026
