问题1:请问flinkcdc下cdc 可以对接 云上的 polardb-x 吗?
问题2: 直接对接 rds 是吧?昨天对接 polardb-x 的时候 老是解析 分库分表字段失败。
Flink CDC 可以对接云上的 PolarDB-X,只要满足以下两个条件:
PolarDB-X 支持 MySQL 协议。Flink CDC 支持的数据库类型包括 MySQL、PostgreSQL 和 Oracle。由于 PolarDB-X 支持 MySQL 协议,因此可以使用 Flink CDC 对其进行数据抽取。
PolarDB-X 的 binlog 格式为 ROW 格式。Flink CDC 可以通过读取数据库的 binlog 实现数据抽取,但需要确保 binlog 格式为 ROW 格式。PolarDB-X 默认使用 ROW 格式,因此不需要进行额外的配置。
在使用 Flink CDC 对接 PolarDB-X 时,可以参考 Flink 官方文档中提供的示例代码和配置文件,根据具体的需求进行配置和调整。例如,可以使用 Flink SQL API 或者 Flink DataStream API 来编写 CDC 抽取任务,同时需要配置正确的连接信息和表信息,以实现数据的抽取和处理。
需要注意的是,由于 PolarDB-X 是云上的分布式数
"回答1:
回答2:可以的,polardb-x 还需要分库分表这事有点不太合理了。polardb-x在业务上可以不分库分表,单表数据量基本可忽略,和数据同步没关系。此回答整理至钉群“Flink CDC 社区”。"
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。