现在Flink CDC-3.0.1支持从PG(16.x)的备库复制嘛?
Flink CDC 3.0.1版本支持从PostgreSQL的备库进行数据复制。
Flink CDC(Change Data Capture)是Apache Flink的一个子项目,它允许用户通过捕获日志信息来实时地同步数据库中的数据变更。随着3.0版本的发布,Flink CDC不仅作为一个数据源,还成为了一个基于Flink的端到端流式ELT(Extract, Load, Transform)数据集成框架。这意味着它提供了更全面的数据集成能力,包括从备份数据库中捕获数据变更。
在使用Flink CDC从PostgreSQL备库复制数据时,需要确保PostgreSQL的主数据库配置了逻辑解码(logical decoding),这是因为Flink CDC使用的是基于日志的逻辑解码方式来捕获数据变更。在PostgreSQL的主数据库中,需要设置wal_level
参数为logical
,以启用逻辑解码功能。
此外,Flink CDC的文档和社区资源提供了关于如何配置和管理Flink CDC数据源的详细指导,以及如何解决数据源连接和同步过程中可能遇到的问题。如果您需要具体的操作步骤和实践案例,可以参考相关的技术文章和教程,这些通常会涵盖从环境搭建到数据同步测试的全流程体验。
综上所述,Flink CDC 3.0.1版本确实支持从PostgreSQL的备库复制数据,但需要确保主数据库的相关配置已经正确设置,并且遵循Flink CDC的配置和管理指南来实现数据同步。
目前不支持。3.1快发了可以试试,我这边还没做测试,debezium那边说支持,
https://github.com/ververica/flink-cdc-connectors/pull/3034
。此回答来自钉群Flink CDC 社区。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。