MySQL

提供从 MySQL 数据库读取快照数据和增量数据的能力，并提供端到端的整库数据同步能力

✅

❌

Flink 1.16、
Flink 1.20

PostgreSQL（公测）

提供从 Postgres 数据库读取快照数据和增量数据的能力

✅

❌

Flink 1.16、
Flink 1.20

MongoDB（公测）

提供从 MongoDB 数据库读取快照数据和增量数据的能力

✅

❌

Flink 1.16、
Flink 1.20

Kafka

支持从 Kafka 同步 JSON、Debezium-JSON 等格式的数据
提供整库同步、Schema 变更同步到 Kafka 的能力

✅

✅

Flink 1.16、
Flink 1.20

Paimon

提供整库同步、Schema 变更同步到 Paimon 的能力

❌

✅

Flink 1.16、
Flink 1.20

Iceberg （公测）

提供整库同步、Schema 变更同步到 Iceberg 的能力

Starrocks

提供整库同步、Schema 变更同步到 Starrocks 的能力

❌

✅

Flink 1.16、
Flink 1.20

Doris

提供整库同步、Schema 变更同步到 Doris 的能力

❌

✅

Flink 1.16、
Flink 1.20

Bytehouse CDW

提供整库同步到 Bytehouse CDW 的能力

❌

✅

Flink 1.16、
Flink 1.20

Elasticsearch

提供整库同步、Schema 变更同步到 Elasticsearch 的能力

❌

✅

Flink 1.16、
Flink 1.20

VikingDB（公测）

提供整库同步到 VikingDB 的能力

❌

✅

Flink 1.16、
Flink 1.20

HBase（公测）

提供整库同步到 HBase 的能力

❌

✅

Flink 1.16、
Flink 1.20

Redis（公测）

提供整库同步到 Redis 的能力

❌

✅

Flink 1.16、
Flink 1.20

Values

提供数据写入调试的能力

❌

✅

Flink 1.16、
Flink 1.20

TOS（公测中）

提供捕获 TOS 对象元数据变更的能力，
支持存量扫描以及对象创建、覆盖和删除事件的持续消费。

✅

❌

Flink 1.16、
Flink 1.20

add.column

增加字段

alter.column.type

变更字段类型

create.table

自动建表

drop.column

删除字段

drop.table

删除表

rename.column

重命名字段

truncate.table

清空数据表