本文介绍流式计算 Flink 版支持的 CDC Pipeline 连接器。
下表列举了流式计算 Flink 版目前提供的连接器,以及各连接器支持的源表 & 结果类型。
连接器 | 描述 | 源表 | 结果表 | 引擎版本 |
---|---|---|---|---|
MySQL | 提供从 MySQL 数据库读取快照数据和增量数据的能力,并提供端到端的整库数据同步能力 | ✅ | ❌ | Flink 1.16、 |
Bytehouse CDW | 提供整库同步到 Bytehouse CDW 的能力 | ❌ | ✅ | Flink 1.16、 |
Paimon | 提供整库同步、Schema 变更同步到 Paimon 的能力 | ❌ | ✅ | Flink 1.16、 |
Starrocks | 提供整库同步、Schema 变更同步到 Starrocks 的能力 | ❌ | ✅ | Flink 1.16、 |
Doris | 提供整库同步、Schema 变更同步到 Doris 的能力 | ❌ | ✅ | Flink 1.16、 |
Kafka | 提供整库同步、Schema 变更同步到 Kafka 的能力 | ❌ | ✅ | Flink 1.16、 |
Values | 提供数据写入调试的能力 | ❌ | ✅ | Flink 1.16、 |