请问flink cdc oracle 可以实现从oracle 19c的备库(data guard)，

请问flink cdc oracle 可以实现从oracle 19c的备库(data guard)，实时同步数据吗？

展开

收起

雪哥哥 2022-10-30 10:04:26 3304 0

4 条回答

写回答

取消提交回答

1777842348277221

老哥你这个实现了吗？
CDC抽取数据的时候DG库没有写的权限，那
LOG_MINING_FLUSH 这张表的LAST_SCN游标数据怎么记录？

2024-06-20 10:38:42

赞同展开评论打赏
喜欢猪猪

网站：http://ixiancheng.cn/ 微信订阅号：小马哥学JAVA

可以，Oracle连接器已经将底层的CDC细节屏蔽，整个实时同步链路，用户只需要几行Flink SQL，不用任何开发Java代码，就可以将Oracle的变更实时捕获，Oracle CDC 连接器支持 LogMiner 和 XStream API 两种方式捕获变更事件。理论上能支持各种 Oracle 版本，目前 Flink CDC 项目里测试了 Oracle 11，12 和 19 三个版本。使用 Oracle CDC 连接器，用户只需要声明如下 Flink SQL 就能实时捕获 Oracle 数据库中的变更数据。

2022-11-24 20:11:33

赞同展开评论打赏
飞云觅宙

十年摸盘键，代码未曾试。今日码示君，谁有上云事。

可以，Flink connector Oracle CDC 实时同步数据到MySQL（Oracle19c）需要配置Oracle，主要包含。开启Archive log 开启数据库和数据表的supplemental log 创建CDC用户并赋予权限

注意：不要使用Oracle的SYS和SYSTEM用户做为CDC用户。因为这两个用户能够捕获到大量Oracle数据库内部的变更信息，对于业务数据来说是不必要的。Debezium会过滤掉这两个用户捕获到的变更内容。

安装Oracle的机器上，进入Sqlplus。然后开启Archive log。Oracle配置完成后切换到 Flink 目录，在 Flink SQL CLI 中使用 Flink DDL 创建表创建从相应数据库表中捕获更改数据的表。

在定义一个数据流出到MySQL的表，完成以上配置；Flink connector Oracle CDC实时数据同步到MySQL的操作就完成了。

2022-11-24 15:08:17

赞同 1 展开评论打赏
穿过生命散发芬芳

Oracle CDC 连接器支持 LogMiner 和 XStream API 两种方式捕获变更事件。支持 Oracle 11，12 和 19 三个版本。使用 Oracle CDC 连接器，用户只需要声明如下 Flink SQL 就能实时捕获 Oracle 数据库中的变更数据。

2022-11-24 07:30:27

赞同展开评论打赏