在 Flink CDC 中,Oracle 数据库的连接通常是通过使用 Oracle LogMiner 进行的。根据 Oracle 的官方文档,Oracle LogMiner 只能在主库上运行,因为它需要访问主库的归档日志或在线重做日志。
因此,对于 Flink CDC,通常只能连接到 Oracle 的主库进行数据采集和变更捕获。连接到 Oracle 的从库(standby database)进行数据采集是不被支持的。
如果你需要将 Flink 连接到 Oracle 的从库以进行数据采集,可能需要考虑其他解决方案,例如使用数据库复制工具将数据复制到另一个支持 CDC 的数据库(如 PostgreSQL),然后使用 Flink CDC 连接到该数据库进行采集。
在 Flink CDC 中,Oracle 数据库可以连接到从库(Secondary Database),以实现数据同步和备份等功能。
连接到 Oracle 从库的方式与连接到主库的方式基本相同,您可以使用 Flink CDC 提供的 Oracle CDC Connector,在配置文件中指定从库的连接参数。具体而言,您可以在 Oracle CDC Connector 的配置文件中设置以下参数:
Copy
"connection-url": "jdbc:oracle:thin:@//secondary_host:1521/service_name",
"connection-user": "user",
"connection-password": "password"
其中,connection-url 参数指定从库的连接地址和服务名称等信息,可以与主库的连接地址不同;connection-user 参数和 connection-password 参数分别指定从库的用户名和密码,可以与主库的用户名和密码不同。
需要注意的是,在使用 Oracle 从库时,您需要确保从
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。