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

Flink CdC 中的 source 支持这个吗?

在Flink CDC中,scan.startup.mode设置为initial模式会执行一个全量快照,也就是从指定的Oracle表中读取整个表的数据,并将其作为初始快照。怎么看有没有限制? + "'debezium.log.mining.strategy' = 'online_catalog',\r\n"

  • "'debezium.log.mining.archive.destination.name' = 'log_archive_dest_ftss_z00r',\r\n"
  • "'debezium.log.mining.continuous.mine'='true',\r\n"
  • "'debezium.database.tablename.case.insensitive'='false',\r\n"
    • "'debezium.schema.include.list'='CDCTEST',\r\n"
    • "'debezium.schema.exclude.list'='ANONYMOUS,APEX_030200,APEX_PUBLIC_USER,APPQOSSYS,BI,CTXSYS,DBSNMP,DIP,EXFSYS,FLOWS_FILES,HR,IX,MDDATA,MDSYS,MGMT_VIEW,OE,OLAPSYS,ORACLE_OCM,ORDDATA,ORDPLUGINS,ORDSYS,OUTLN,OWBSYS,OWBSYS_AUDIT,PM,PUBLIC,SCOTT,SH,SI_INFORMTN_SCHEMA,SPATIAL_CSW_ADMIN_USR,SPATIAL_WFS_ADMIN_USR,SYS,SYSMAN,SYSTEM,WMSYS,XDB,XS$NULL',\r\n" //无此参数
    • "'debezium.table.include.list'='CDCTEST.FDU01_Z00R',\r\n" //无此参数
  • "'debezium.schema-name'='CDCTEST',\r\n" //无此参数
  • "'table-name' = 'FDU01_Z00R')"

展开
收起
小小鹿鹿鹿 2024-05-01 08:55:46 33 0
1 条回答
写回答
取消 提交回答
  • 去debezium看。此回答来自钉群Flink CDC 社区 。

    2024-05-01 13:01:46
    赞同 2 展开评论 打赏

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

相关产品

  • 实时计算 Flink版
  • 相关电子书

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