Flink CDC是Apache Flink的一组源连接器,支持从各种数据库中实时读取存量历史数据和增量变更数据。根据目前的官方情况,Flink CDC主要支持的数据库类型包括MySQL、PostgreSQL、Oracle和SQL Server等,并未明确包含国产数据库达梦和人大金仓。
然而,对于未被官方直接支持的数据库类型,如达梦,可以通过实现自定义的FlinkCDCDeserializationSchema和FlinkCDCFormatFunction来为其提供支持。具体来说,已经在flink-connector-jdbc中实现了对国产数据库达梦(V8)的支持。
FlinkCDC官方支持的数据库主要包括MySQL、PostgreSQL、Oracle和SQL Server等,但目前尚未原生支持达梦数据库和人大金仓数据库。然而,Flink是一个开源项目,允许社区根据需求进行扩展和定制。如果你希望在FlinkCDC中添加对达梦数据库或人大金仓数据库的支持,你可以通过实现自定义的FlinkCDCDeserializationSchema和FlinkCDCFormatFunction来实现。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。