Flink CDC is a streaming data integration tool
Documentation: https://ververica.github.io/flink-cdc-connectors/release-3.0
Flink CDC 3.0.1 (tar, asc, sha512)
The binary release can be verified by public key with fingerprint F8822354BF424A5CFF9AFD57BAF388953EF5327A
.
All connectors are release in JAR and available in Maven central repository.
All connectors are release in JAR and available in Maven central repository.
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)
Documentation: https://ververica.github.io/flink-cdc-connectors/release-3.0
Flink CDC 3.0.0 (tar, asc, sha512)
The binary release can be verified by public key with fingerprint C460A307EAF2701FC9D774EF96719B746D3D0C8A
.
All connectors are release in JAR and available in Maven central repository.
All connectors are release in JAR and available in Maven central repository.
default
as name of namespace and schema. (#2774)values
cdc pipeline connector.
in names (#2488)tikv disk full
failure (#2402)pendingRecords
and numRecordsInErrors
metrics for sourcescanFullChangelog
feature & deprecate copyExisting
optionDocumentation: https://ververica.github.io/flink-cdc-connectors/release-2.4
tikv disk full
failure (#2402)Documentation: https://ververica.github.io/flink-cdc-connectors/release-2.4
Documentation: https://ververica.github.io/flink-cdc-connectors/release-2.4
Documentation: https://ververica.github.io/flink-cdc-connectors/release-2.3
Documentation: https://ververica.github.io/flink-cdc-connectors/release-2.2/
Documentation: https://ververica.github.io/flink-cdc-connectors/release-2.1/
Gunnar Morling, Jark Wu, Jiabao Sun, Leonard Xu, MartijnVisser, Marton Balassi, Shengkai, Tamas Kiss, Tamas Zseder, Zongwen Li, dongdongking008, frey66, gongzhongqiang, ili zh, jpatel, lsy, luoyuxia, manmao, mincwang, taox, tuple, wangminchao, yangbin09