Releases: apache/flink-cdc
Release 3.6.0
Release Announcement
https://flink.apache.org/2026/03/30/apache-flink-cdc-3.6.0-release-announcement/
Release Notes
Downloads
We highly recommend all users to upgrade to Flink CDC 3.6.0.
Important
This version only supports JDK 11 and higher versions.
Apache Flink CDC 3.6.0 tar
Apache Flink CDC 3.6.0 for Flink 1.20.x (asc, sha512)
Apache Flink CDC 3.6.0 for Flink 2.2.x (asc, sha512)
Apache Flink CDC 3.6.0 Source Release (asc, sha512)
Pipeline Connectors Jars
- MySQL (2.2: jar asc sha1, 1.20: jar asc sha1)
- Doris (2.2: jar asc sha1, 1.20: jar asc sha1)
- Elasticsearch (2.2: jar asc sha1, 1.20: jar asc sha1)
- Fluss (2.2: jar asc sha1, 1.20: jar asc sha1)
- Hudi (2.2: jar asc sha1, 1.20: jar asc sha1)
- Iceberg (2.2: jar asc sha1, 1.20: jar asc sha1)
- Kafka (2.2: jar asc sha1, 1.20: jar asc sha1)
- MaxCompute (2.2: jar asc sha1, 1.20: jar asc sha1)
- OceanBase (2.2: jar asc sha1, 1.20: jar asc [sha1](ht...
Release 3.5.0
Release Announcement
https://flink.apache.org/2025/09/26/apache-flink-cdc-3.5.0-release-announcement/
Release Notes
Contributors
We would like to express gratitude to all the contributors working on this release:
Chao Zhang, ChengJie1053, gongzhongqiang, Hang Ruan, Hongshun Wang, hql0312, Ihor Mielientiev, Junbo Wang, junmuz, kangzai, Kunni, Lanny Boarts, linjianchang, lvyanquan, Marta Paes, MOBIN, Naci Simsek, North Lin, ouyangwulin, proletarians, Sachin Mittal, Sergei Morozov, SeungMin, Shawn Huang, suhwan, suntectec, tbpure, Thorne, Tianzhu Wen, Vinh Pham, wangjunbo, wudi, wuzexian, Xin Gong, yuanoOo, yuxiqian, zhangchao.doovvv, zhuxt2015, Мухутдинов Артур
Downloads
We highly recommend all users to upgrade to Flink CDC 3.5.0.
Apache Flink CDC 3.5.0 tar
Apache Flink CDC 3.5.0 (asc, sha512)
Apache Flink CDC 3.5.0 Source Release (asc, sha512)
Pipeline Connectors Jars
- MySQL Pipeline Connector 3.5.0 (jar, asc, sha1)
- Doris Pipeline Connector 3.5.0 (jar, asc, sha1)
- StarRocks Pipeline Connector 3.5.0 (jar, asc, sha1)
- Kafka Pipeline Connector 3.5.0 (jar, asc, sha1)
- Paimon Pipeline Connector 3.5.0 (jar, asc, sha1)
- Elasticsearch Pipeline Connector 3.5.0 (jar, asc, sha1)
- OceanBase Pipeline Connector 3.5.0 (jar, asc, sha1)
- MaxCompute Pipeline Connector 3.5.0 (jar, asc, sha1)
- Iceberg Pipeline Connector 3.5.0 (jar, asc, sha1)
- PostgreSQL Pipeline Connector 3.5.0 (jar, asc, sha1)
- Fluss Pipeline Connector 3.5.0 (jar, asc, sha1)
Source Connector Jars
- Db2 Source connector 3.5.0 (jar, asc, sha1)
- MongoDB Source connector 3.5.0 (jar, asc, sha1)
- MySQL Source connector 3.5.0 (jar, asc, sha1)
- OceanBase Source connector 3.5.0 (jar, asc, sha1)
- Oracle Source connector 3.5.0 (jar, asc, sha1)
- PostgreSQL Source connector 3.5.0 (jar, asc, sha1)
- Microsoft SQL Server Source connector 3.5.0 (jar, [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3....
release-3.4.0
Release Announcement
https://flink.apache.org/2025/05/16/apache-flink-cdc-3.4.0-release-announcement/
Release Notes
Contributors
We would like to express gratitude to all the contributors working on this release:
911432, chenhongyu, ConradJam, Ferenc Csaky, gongzhongqiang, Hang Ruan, He Wang, hiliuxg, Hongshun Wang, Jason Zhang, Jiabao Sun, Junbo Wang, Jzjsnow, Kevin Caesar, Kevin Wang, Kunni, Leonard Xu, lidoudou1993, linjianchang, liuxiaodong, lvyanquan, lzshlzsh, MOBIN-F, moses, North Lin, Olivier, ouyangwulin, Petrichor, proletarians, qinghuanwang, Qingsheng Ren, Robin Moffatt, Runkang He, Sergei Morozov, Seung-Min Lee, Shawn Huang, stayrascal, Thorne, Timi, Umesh Dangat, Vincent-Woo, Vinh Pham, wenmo, Wink, wudi, Xin Gong, yohei yoshimuta, yuanoOo, yuxiqian, zhangzheng
Downloads
We highly recommend all users to upgrade to Flink CDC 3.4.0.
Apache Flink CDC 3.4.0 tar
Apache Flink CDC 3.4.0 (asc, sha512)
Apache Flink CDC 3.4.0 Source Release (asc, sha512)
Pipeline Connectors Jars
- MySQL Pipeline Connector 3.4.0 (jar, asc, sha1)
- Doris Pipeline Connector 3.4.0 (jar, asc, sha1)
- StarRocks Pipeline Connector 3.4.0 (jar, asc, sha1)
- Kafka Pipeline Connector 3.4.0 (jar, asc, sha1)
- Paimon Pipeline Connector 3.4.0 (jar, asc, sha1)
- Elasticsearch Pipeline Connector 3.4.0 (jar, asc, sha1)
- OceanBase Pipeline Connector 3.4.0 (jar, asc, sha1)
- MaxCompute Pipeline Connector 3.4.0 (jar, asc, sha1)
- Iceberg Pipeline Connector 3.4.0 (jar, asc, sha1)
Source Connector Jars
- Db2 source connector 3.4.0 (jar, asc, sha1)
- MongoDB source connector 3.4.0 (jar, asc, sha1)
- MySQL source connector 3.4.0 (jar, asc, sha1)
- OceanBase source connector 3.4.0 (jar, asc, sha1)
- Oracle source connector 3.4.0 (jar, asc, sha1)
- Postgres source connector 3.4.0 (jar, asc, sha1)
- Microsoft SQL Server source connector 3.4.0 (jar, asc, sha1)
- TiDB source connector 3.4.0 (jar, asc, sha1)
- Vitess source connector 3.4.0 (jar, [asc](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-vitess-cdc/3.4.0/flink-sql-connector-...
Release 3.3.0
Release Announcement
https://flink.apache.org/2025/01/21/apache-flink-cdc-3.3.0-release-announcement/
Release Notes
https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12354855
Contributors
We would like to express gratitude to all the contributors working on this release:
ConradJam, Hang Ruan, Hongshun Wang, Jason Zhang, Junbo wang, Jzjsnow, Kunni, Leonard Xu, MOBIN, North Lin, Olivier, Petrichor, Robin Moffatt, Runkang He, Sergei Morozov, Seung-Min Lee, Shawn Huang, Thorne, Timi, Umesh Dangat, Wink, Xin Gong, hiliuxg, liuxiaodong, moses, ouyangwulin, stayrascal, wenmo, wudi, yuanoOo, yuxiqian, MOBIN-F, helloliuxg, jzjsnow, molin.lxd, wuzhiping, zhangchaoming.zcm
Downloads
We highly recommend all users to upgrade to Flink CDC 3.3.0.
Apache Flink CDC 3.3.0 tar
Apache Flink CDC 3.3.0 (asc, sha512)
Apache Flink CDC 3.3.0 Source Release (asc, sha512)
Pipeline Connectors Jars
- MySQL Pipeline Connector 3.3.0 (jar, asc, sha1)
- Doris Pipeline Connector 3.3.0 (jar, asc, sha1)
- StarRocks Pipeline Connector 3.3.0 (jar, asc, sha1)
- Kafka Pipeline Connector 3.3.0 (jar, asc, sha1)
- Paimon Pipeline Connector 3.3.0 (jar, asc, sha1)
- Elasticsearch Pipeline Connector 3.3.0 (jar, asc, sha1)
- OceanBase Pipeline Connector 3.3.0 (jar, asc, sha1)
- MaxCompute Pipeline Connector 3.3.0 (jar, asc, sha1)
Source Connector Jars
- Db2 source connector 3.3.0 (jar, asc, sha1)
- MongoDB source connector 3.3.0 (jar, asc, sha1)
- MySQL source connector 3.3.0 (jar, asc, sha1)
- OceanBase source connector 3.3.0 (jar, asc, sha1)
- Oracle source connector 3.3.0 (jar, asc, sha1)
- Postgres source connector 3.3.0 (jar, asc, sha1)
- Microsoft SQL Server source connector 3.3.0 (jar, asc, sha1)
- TiDB source connector 3.3.0 (jar, asc, sha1)
- Vitess source connector 3.3.0 (jar, asc, sha1)
For more details, check the updated documentation and the release notes. We encourage you to download the release and share your feedback with the community through the Flink mailing lists or JIRA.
Release 3.2.1
Release Announcement
https://flink.apache.org/2024/11/27/apache-flink-cdc-3.2.1-release-announcement/
Release Notes
https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12355099
Contributors
We would like to express gratitude to all the contributors working on this release:
yuxiqian, Xin Gong, Hang Ruan, wudi, qg-lin, Timi988, lvyanquan, ConradJam, Runkang He, Junbo wang, MOBIN, Leonard Xu, Sergei Morozov, liuzeshan
Downloads
We highly recommend all users to upgrade to Flink CDC 3.2.1.
Apache Flink CDC 3.2.1 tar
Apache Flink CDC 3.2.1 (asc, sha512)
Apache Flink CDC 3.2.1 Source Release (asc, sha512)
Pipeline Connectors Jars
- MySQL Pipeline Connector 3.2.1 (jar, asc, sha1)
- Doris Pipeline Connector 3.2.1 (jar, asc, sha1)
- StarRocks Pipeline Connector 3.2.1 (jar, asc, sha1)
- Kafka Pipeline Connector 3.2.1 (jar, asc, sha1)
- Paimon Pipeline Connector 3.2.1 (jar, asc, sha1)
- Elasticsearch Pipeline Connector 3.2.1 (jar, asc, sha1)
Source Connector Jars
- Db2 source connector 3.2.1 (jar, asc, sha1)
- MongoDB source connector 3.2.1 (jar, asc, sha1)
- MySQL source connector 3.2.1 (jar, asc, sha1)
- OceanBase source connector 3.2.1 (jar, asc, sha1)
- Oracle source connector 3.2.1 (jar, asc, sha1)
- Postgres source connector 3.2.1 (jar, asc, sha1)
- Microsoft SQL Server source connector 3.2.1 (jar, asc, sha1)
- TiDB source connector 3.2.1 (jar, asc, sha1)
- Vitess source connector 3.2.1 (jar, asc, sha1)
For more details, check the updated documentation and the release notes. We encourage you to download the release and share your feedback with the community through the Flink mailing lists or JIRA.
Release 3.2.0
PatrickRen
Qingsheng Ren
Release Announcement
https://flink.apache.org/2024/09/05/apache-flink-cdc-3.2.0-release-announcement/
Release Notes
https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12354594
Contributors
We would like to express gratitude to all the contributors working on this release:
ChengJie1053, ConradJam, FangXiangmin, GOODBOY008, Hang Ruan, He Wang, Hongshun Wang, Jiabao Sun, Joao Boto, Junbo wang, Kunni, Laffery, Leonard Xu, MOBIN, Muhammet Orazov, North Lin, PONYLEE, Paul Lin, Qingsheng Ren, SeungMin, Shawn Huang, Thorne, Wink, Xie Yi, Xin Gong, Zhongmin Qiao, Zmm, gong, gongzhongqiang, hk__lrzy, joyCurry30, lipl, lvyanquan, ouyangwulin, skylines, wuzexian, yanghuaiGit, yux, yuxiqian, 鼎昕
Downloads
Apache Flink CDC 3.2.0 tar
Apache Flink CDC 3.2.0 (asc, sha512)
Apache Flink CDC 3.2.0 Source Release (asc, sha512)
Pipeline Connectors Jars
- MySQL Pipeline Connector 3.2.0 (jar, asc, sha1)
- Doris Pipeline Connector 3.2.0 (jar, asc, sha1)
- StarRocks Pipeline Connector 3.2.0 (jar, asc, sha1)
- Kafka Pipeline Connector 3.2.0 (jar, asc, sha1)
- Paimon Pipeline Connector 3.2.0 (jar, asc, sha1)
- Elasticsearch Pipeline Connector 3.2.0 (jar, asc, sha1)
Source Connector Jars
- Db2 source connector 3.2.0 (jar, asc, sha1)
- MongoDB source connector 3.2.0 (jar, asc, sha1)
- MySQL source connector 3.2.0 (jar, asc, sha1)
- OceanBase source connector 3.2.0 (jar, asc, sha1)
- Oracle source connector 3.2.0 (jar, asc, sha1)
- Postgres source connector 3.2.0 (jar, asc, sha1)
- Microsoft SQL Server source connector 3.2.0 (jar, asc, sha1)
- TiDB source connector 3.2.0 (jar, asc, sha1)
- Vitess source connector 3.2.0 (jar, asc, sha1)
Release 3.1.1
Release Announcement
https://flink.apache.org/2024/06/18/apache-flink-cdc-3.1.1-release-announcement/
Release Notes
https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12354763
Downloads
Apache Flink CDC 3.1.1 tar
Apache Flink CDC 3.1.1 (asc, sha512)
Apache Flink CDC 3.1.1 Source Release (asc, sha512)
Pipeline Connectors Jars
- MySQL Pipeline Connector 3.1.1 (jar, asc, sha1)
- Doris Pipeline Connector 3.1.1 (jar, asc, sha1)
- StarRocks Pipeline Connector 3.1.1 (jar, asc, sha1)
- Kafka Pipeline Connector 3.1.1 (jar, asc, sha1)
- Paimon Pipeline Connector 3.1.1 (jar, asc, sha1)
Source Connector Jars
- Db2 source connector 3.1.1 (jar, asc, sha1)
- MongoDB source connector 3.1.1 (jar, asc, sha1)
- MySQL source connector 3.1.1 (jar, asc, sha1)
- OceanBase source connector 3.1.1 (jar, asc, sha1)
- Oracle source connector 3.1.1 (jar, asc, sha1)
- Postgres source connector 3.1.1 (jar, asc, sha1)
- Microsoft SQL Server source connector 3.1.1 (jar, asc, sha1)
- TiDB source connector 3.1.1 (jar, asc, sha1)
- Vitess source connector 3.1.1 (jar, asc, sha1)
Release 3.1.0
Release Announcement
https://flink.apache.org/2024/05/17/apache-flink-cdc-3.1.0-release-announcement/
Release Notes
https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12354387
Downloads
Apache Flink CDC 3.1.0 tar
Apache Flink CDC 3.1.0 (asc, sha512)
Apache Flink CDC 3.1.0 Source Release (asc, sha512)
Pipeline Connectors Jars
- MySQL Pipeline Connector 3.1.0 (jar, asc, sha1)
- Doris Pipeline Connector 3.1.0 (jar, asc, sha1)
- StarRocks Pipeline Connector 3.1.0 (jar, asc, sha1)
- Kafka Pipeline Connector 3.1.0 (jar, asc, sha1)
- Paimon Pipeline Connector 3.1.0 (jar, asc, sha1)
Source Connector Jars
- Db2 source connector 3.1.0 (jar, asc, sha1)
- MongoDB source connector 3.1.0 (jar, asc, sha1)
- MySQL source connector 3.1.0 (jar, asc, sha1)
- OceanBase source connector 3.1.0 (jar, asc, sha1)
- Oracle source connector 3.1.0 (jar, asc, sha1)
- Postgres source connector 3.1.0 (jar, asc, sha1)
- Microsoft SQL Server source connector 3.1.0 (jar, asc, sha1)
- TiDB source connector 3.1.0 (jar, asc, sha1)
- Vitess source connector 3.1.0 (jar, asc, sha1)
Release 3.0.1
Release Notes
Documentation: https://ververica.github.io/flink-cdc-connectors/release-3.0
Downloads
Flink CDC
Flink CDC 3.0.1 (tar, asc, sha512)
The binary release can be verified by public key with fingerprint F8822354BF424A5CFF9AFD57BAF388953EF5327A.
Flink CDC Pipeline Connectors
All connectors are release in JAR and available in Maven central repository.
- Apache Doris pipeline connector 3.0.1 (jar, asc, sha1)
- MySQL pipeline connector 3.0.1 (jar, asc, sha1)
- StarRocks pipeline connector 3.0.1 (jar, asc, sha1)
- Values pipeline connector 3.0.1 (for testing purpose, jar, asc, sha1)
Flink CDC Source Connectors
All connectors are release in JAR and available in Maven central repository.
- Db2 source connector 3.0.1 (jar, asc, sha1)
- MongoDB source connector 3.0.1 (jar, asc, sha1)
- MySQL source connector 3.0.1 (jar, asc, sha1)
- OceanBase source connector 3.0.1 (jar, asc, sha1)
- Oracle source connector 3.0.1 (jar, asc, sha1)
- Postgres source connector 3.0.1 (jar, asc, sha1)
- Microsoft SQL Server source connector 3.0.1 (jar, asc, sha1)
- TiDB source connector 3.0.1 (jar, asc, sha1)
- Vitess source connector 3.0.1 (jar, asc, sha1)
Improvements and Bug fixes
1.[cdc-base][hotfix] Fix SourceSplitSerializer to get totalFinishedSplitSize from recovery in 4th version
2.[hotfix][cdc-common] Fix NoSuchMethodError of CollectionUtil.newHashMapWithExpectedSize
3.[cdc][e2e] Unify logic to clean docker image when connector e2e test finished (#2978)
4.[pipeline-connector][mysql] fix timestamp with timezone format (#2952)
5.[doc] fix invalid page in website and update yaml in tutorial.
6.[cdc-connector][oracledb] Fix oracle read exceed high_watermark in backfill phase
7.[pipeline-connector][starrocks] Optimize char type mapping for starrocks pipeline connector (#2895)
8.[pipeline-connector][doris][starrocks] Remove SimpleDateFormat for thread safe (#2954)
9.[build] Add github labeler for pipeline connector. (#2851)
10.[docs][cdc-connector][oceanbase] update docker image and os compatibility in quickstart (#2897)
11.[docs] Add Supported Connectors and Supported Flink Versions to Overview. (#2920)
12.[cdc-common][pipeline-doris] Fix typo and wrong value for 'precision' of time type. (#2886)
13.[cdc-connector][mongodb] Avoid mongodb source to read data after high_watermark in backfill phase (#2893)
14.[cdc-connector][oceanbase] Fallback to current timestamp when query gts failure (#2868)
15.[cdc-connector][sqlserver][tests] Fix UT errors by correcting right output (#2864)
16.[cdc] Add Deprecated annotation to source function which connector implemented incremental
17.[hotfix] Remove mysqlToDoris.yml
18.[hotfix] Fix BinaryRecordData deserialize
19.[postgres] Add commits of PostgresConnection back to distinguish with debezium's origin class (#2839)
20.[hotfix][cdc-rumtime][minor] Clean up useless code in BinaryRecordDataSerializer (#2845)
21.[cdc-connector][sqlserver] Fix SqlServerTableSource params order error (#2847)
22.[docs] Fix overview docs to remove prefix of pipeline options (#2833)
23.[3.0][docs] fix mysql pipeline connector option in readme (#2834)
Contributor List (sorted alphabetically)
- GOODBOY008
- He Wang
- Hongshun Wang
- joyCurry30
- Kunni
- Shawn Huang
- TorinJie
- Xin Gong
- gongzhongqiang
- xuzifu666
- 张田
Release 3.0.0
Release Notes
Documentation: https://ververica.github.io/flink-cdc-connectors/release-3.0
Downloads
Flink CDC
Flink CDC 3.0.0 (tar, asc, sha512)
The binary release can be verified by public key with fingerprint C460A307EAF2701FC9D774EF96719B746D3D0C8A.
Flink CDC Pipeline Connectors
All connectors are release in JAR and available in Maven central repository.
- Apache Doris pipeline connector 3.0.0 (jar, asc, sha1)
- MySQL pipeline connector 3.0.0 (jar, asc, sha1)
- Starrocks pipeline connector 3.0.0 (jar, asc, sha1)
- Values pipeline connector 3.0.0 (for testing purpose, jar, asc, sha1)
Flink CDC Source Connectors
All connectors are release in JAR and available in Maven central repository.
- Db2 source connector 3.0.0 (jar, asc, sha1)
- MongoDB source connector 3.0.0 (jar, asc, sha1)
- MySQL source connector 3.0.0 (jar, asc, sha1)
- OceanBase source connector 3.0.0 (jar, asc, sha1)
- Oracle source connector 3.0.0 (jar, asc, sha1)
- Postgres source connector 3.0.0 (jar, asc, sha1)
- Microsoft SQL Server source connector 3.0.0 (jar, asc, sha1)
- TiDB source connector 3.0.0 (jar, asc, sha1)
- Vitess source connector 3.0.0 (jar, asc, sha1)
Features and Improvements
- [pipeline-connector][starrocks] Fix char/varchar length inconsistency between cdc and starrocks (#2830)
- [cdc-cli][cdc-composer] Use "source-table" and "sink-table" as keywords of route (#2825)
- [build][hotfix] Remove duplicate dependency (#2826)
- [cdc-cli][cdc-dist] Support loading global config from FLINK_CDC_HOME (#2822)
- [cdc-common][hotfix] Remove redundant prefix of pipeline options (#2821)
- [cdc-source-connector][oceanbase][e2e] Add OceanBase e2e test case (#2521)
- [build] Use flink-shaded-force-shading to force all submodules to generate dependency-reduced-pom.xml
- [build] Use ${project.version} instead of ${revision} for dependency version
- [build] Skip maven-deploy-plugin for test modules and flink-cdc-dist
- [cdc-pipeline-connector][mysql] Fix precision problem of BIT type conversion (#2820)
- [cdc-source-connector][mysql] fix deserialization issue on table metadata binlog event (#2682)
- [pipeline-connector][mysql] Remove unnecessary serverTimeZone in DebeziumEventDeserializationSchema (#2816)
- [build][hotfix] Remove useless suppressions. (#2817)
- [cdc-source-connector][mysql] Fix attempted load of isSuspended in MySqlSplitSerializer::deserializeSplit when cdc version <= 2.2.0 (#2550)
- [cdc-pipeline-connector][mysql] Ensure the inference of MEDIUMINT_UNSIGNED type matches INT type in table schema (#2811)
- [cdc-connector][oceanbase] Add option for obcdc extra configs (#2543)
- [pipeline-connector][mysql] Enable send schema change by default (#2815)
- [3.0][cdc-runtime] Remove waitForFlushSuccess field in request handler (#2812)
- [pipeline-connector][starrocks] Add starrocks pipeline connector (#2765)
- [pipeline-connector][doris] add doris pipeline connector. (#2810)
- [cdc-pipeline-connector][mysql] Ensure the precision inference of DECIMAL type matches table schema
- [3.0][cdc-common & runtime] Remove useless flink imports
- [cdc-pipeline-connector][mysql] Add tests for mysql pipeline connector
- [cdc-pipeline-connector][mysql] Support more mysql types
- [cdc-pipeleine-connecotr][mysql] Send CreateTableEvent in the mysql pipeline connector
- [cdc-pipeline-connector][mysql] Parse the alter statement to generate SchemaChangeEvent
- [cdc-pipeline-connector][mysql] Introduce mysql cdc pipeline DataSource
- [cdc-cli][cdc-composer][cdc-dist] Support submitting job to general Flink environments (#2807)
- [cdc-runtime][hotfix] Setup waitFlushSuccess before responding operator to flush. (#2805)
- [cdc-common] Introduce "pipeline.local-time-zone" config option which help handle time zone well (#2797)
- [cdc-common][hotfix] Remove useless flink imports (#2803)
- [build] Let surefire plugin to keep the full stacktrace on test failure (#2804)
- [pipeline-common] Use column name to check whether the schema contains specific column or not. (#2801)
- [cdc-composer][route][sink] Add name for route and improve name for sink
- [cdc-composer][hotfix] Always chain operator by default
- [cdc-composer][sink] Use correct name for sink operator
- [cdc-runtime] SchemaRegistry should complete the future after making the checkpoint (#2800)
- [cdc-connector][sqlserver][test...