Flink CDC is a distributed data integration tool for real-time and batch data processing built on Apache Flink.
The tool addresses the challenge of capturing and synchronizing data changes across systems in real time. It works by providing multiple API layers to accommodate different use cases: a YAML-based declarative approach for zero-code pipeline definition, and programmatic interfaces for more complex scenarios. The tool handles full database synchronization, sharding table synchronization, schema evolution, and data transformation as core capabilities, allowing users to define sources, sinks, routing rules, and transformation logic that execute on the Flink distributed runtime.
Flink CDC suits organizations that need to move data between databases and systems with minimal latency and without writing custom code. The YAML API makes it accessible to users who prefer declarative configuration, while the underlying Flink architecture supports large-scale distributed deployments. Teams managing complex data pipelines with schema changes, multi-table synchronization, or heterogeneous source and sink systems will find the built-in support for these scenarios valuable. The tool integrates with common databases and systems including MySQL, PostgreSQL, and Kafka, and can write to Paimon for data lake scenarios.
The project maintains active continuous integration with both standard and nightly test workflows. Development activity shows consistent attention to build stability and quality assurance across the codebase.
