
电 话:17332891330
邮 箱:37364077@qq.com
Apache Flink 是支持一个开源的流处理框架,它支持多(duo)种数据源和(he)格式(shi),支持Change Data Capture (CDC) 是支持其中一种功能,用于捕捉数(shu)据库中的支持数据变化并将其转化为事件流。(图片来源网络,支持侵删)
TiDB 支持情(qing)况

TiDB 是支持一个兼容 MySQL 协议的分布式 NewSQL 数据库,它的支持目标是提供混合事务/分析处理(HTAP)能力,至于(yu) Flink CDC 对 TiDB 的(de)支持支持情况,这取决于 Flink 社区是支持否提供了相应(ying)的 CDC connector 来连接 TiDB。

Flink CDC Connectors

Flink CDC 通常通过专门的支持 connector 来实现对不(bu)同数据库的支持,这些 connector 通常是支持由 Flink 社区开发的,它们负责与特定数据库建立连接,支持捕捉变更(geng)数据,支持并将其转换为 Flink 可用的支持流。
支持的支持 CDC Connectors
| 数据库 | CDC Connector 状态 |
| MySQL | 有现成(cheng)的 CDC connector |
| PostgreSQL | 有现成(cheng)的 CDC connector |
| Oracle | 有现成的 CDC connector |
| SQL Server | 有现成的 CDC connector |
| … | … |
TiDB CDC Connector
对于(yu) TiDB,可能需要查看 Flink 社区的最新动态来确定是(shi)否有(you)官方或者第(di)三方提供的 CDC connector,由于 TiDB 基于(yu) Google Spanner 的架构设计,并且兼容 MySQL 协议,如果有对应的 MySQL CDC connector,它可能也能够适配 TiDB。
如何验证
1、查找文档和更新(xin):检查 Flink 官方网站和社区论坛,以获取关于支持的 CDC connectors 的(de)最新信息。
2、GitHub 仓库搜索:在 Apache Flink 的(de) GitHub 仓库中搜索“TiDB”或“CDC connector”,看是否有相(xiang)关的项目或讨论(lun)。
3、尝试使用 MySQL CDC connector:如果存在针对 MySQL 的(de) CDC connector,你可(ke)以尝试将其用(yong)于 TiDB,看(kan)看是否能够正常工作。
4、社区支持:联系 Flink 社区或 TiDB 社区,询问是否有人正在开发或已经开发了(le)相应的 connector。
5、自行开发(fa):如果没有现成的 connector,且你有相应的(de)技术能力,可以(yi)考虑自己开发一个 Flink CDC connector 来支持 TiDB。
归纳来说,Flink CDC 是否支持(chi) TiDB 取决于是否存在或能开发相应的 CDC connector,建议查阅最新的 Flink 文档或社区资源以确认当前状态。