What’s New in Flink CDC 2.2? A Deep Dive into Added Sources and Core Features
The article introduces Flink CDC 2.2, highlighting its expanded support for twelve data sources—including OceanBase, PolarDB‑X, SqlServer, and TiDB—while detailing core features such as the incremental snapshot framework, multi‑version Flink compatibility, dynamic table addition, and numerous bug fixes and performance improvements.
Overview
Flink CDC (CDC Connectors for Apache Flink®) is a set of source connectors that enable real‑time ingestion of both historical and incremental change data from databases such as MySQL, PostgreSQL, Oracle, MongoDB, SqlServer, OceanBase, PolarDB‑X, TiDB and others. It supports both the user‑friendly SQL API and the more powerful DataStream API.
As a next‑generation data integration framework, Flink CDC can replace traditional tools like DataX and Canal for real‑time synchronization, stream data into message queues and data warehouses, and provide powerful data processing capabilities such as real‑time joins, widening, and aggregation via SQL.
Compared with other frameworks, Flink CDC offers full‑incremental integration, lock‑free reads, concurrent reads, automatic schema change synchronization, and a distributed architecture, gaining rapid community adoption.
Signed-in readers can open the original source through BestHub's protected redirect.
This article has been distilled and summarized from source material, then republished for learning and reference. If you believe it infringes your rights, please contactand we will review it promptly.
Alibaba Cloud Developer
Alibaba's official tech channel, featuring all of its technology innovations.
How this landed with the community
Was this worth your time?
0 Comments
Thoughtful readers leave field notes, pushback, and hard-won operational detail here.