开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

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

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

展开
收起
雪哥哥 2022-10-30 10:04:26 3019 0
3 条回答
写回答
取消 提交回答
  • 网站: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
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 热门讨论

    热门文章

    相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载