Flink CDC对于oracle表,只抽取增量数据,这样的配置可以吗?
是的,Flink CDC可以抽取oracle表的增量数据。Flink CDC是一个基于Debezium实现的CDC连接器,支持从Oracle数据库中读取数据的增量变化。借助Flink CDC,您可以构建基于Oracle数据库的实时数据流处理应用程序。
在配置过程中,需要注意的是,Flink CDC需要与Oracle数据库进行集成,因此您可能需要配置相应的连接信息。此外,为了抽取增量数据,您需要在创建源表时指定--scan-startup-mode incremental
参数。
然而,根据官方文档说明,可能存在一些连接问题,例如Flink CDC可能将连接信息中的MY_SERVICE_NAME(Oracle的服务名)误认为SID。如果遇到此类问题,建议仔细阅读Flink CDC涉及到Oracle Connector的源码以找出问题所在并进行相应的调整。
可以的,FlinkCDC对于Oracle表,只抽取增量数据的配置是可以的。在配置中,需要设置debezium.log.mining.strategy
为online_catalog
,并启用增量快照功能。同时,需要设置scan.incremental.snapshot.enabled
为true
。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。