请问 flink cdc中oracle cdc支持动态加表吗。可以停止作业,在原有作业增加同步到表,然后再从检查点重启任务吗?我这边测试增加的表只能同步到增量的数据。
Flink CDC 支持 Oracle CDC 的动态加表功能。在 Oracle CDC 中,动态加表可以通过创建新的 LogMiner session 来实现。当 Oracle 数据库创建新的表时,Flink CDC 会自动检测到该表的存在,并创建相应的 LogMiner session 进行数据同步。
需要注意的是,Oracle CDC 的动态加表功能需要满足一些前提条件,例如:
数据库版本:Oracle CDC 动态加表功能需要 Oracle 11g 及以上版本的支持。
数据库配置:Oracle 数据库需要进行一些特定的配置(例如启用日志归档、开启 SUPPLEMENTAL LOGGING 等),以便 Flink CDC 可以正确地监听数据库的变化。
CDC 配置:在 Flink CDC 中,需要正确配置 Oracle CDC 的参数(例如数据源 URL、用户名、密码、LogMiner session 的配置等),以确保 Flink CDC 正确地监听数据库的变化。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。