当前位置: 首页 > news >正文

FlinkCDC 3.2.0 新增优点 Pattern Replacement in routing rules

新增优点:Pattern Replacement in routing rules

flinkcdc 3.2.0版本相较于3.1.0版本,避免了多表多sink多次写 route 路由的麻烦,类似于统一前后缀的形式多表多sink,通过<>正则,大大减少了书写

官网:
Route | Apache Flink CDC
 

Pattern Replacement in routing rules #

If you’d like to route source tables and rename them to sink tables with specific patterns, replace-symbol could be used to resemble source table names like this:

route:- source-table: source_db.\.*sink-table: sink_db.<>replace-symbol: <>description: route all tables in source_db to sink_db

Then, all tables including source_db.XXX will be routed to sink_db.XXX without hassle.
包括source_db.XXX在内的所有表都将毫无麻烦地路由到sink_db.XXX

应用:

flinkcdc版本升级 mysql to doris 在 lib 下添加依赖jar包:

source:type: mysqlhostname: xxxport: 3306username: rootpassword: xxxtables: adb.\.*,bdb.\.*server-id: 6410-6490server-time-zone: Asia/Shanghaiscan.startup.mode: latest-offsetsink:type: dorisfenodes: xxx:8130,xxx:8130,xxx:8130username: rootpassword: xxxtable.create.properties.light_schema_change: trueroute:- source-table: adb.\.*sink-table: test_sync.adb_db_<>replace-symbol: <>pipeline:name: test_syncparallelism: 1

adb会根据route路由规则进行整库同步,bdb则会根据默认的无路由规则进行整库同步。

数据库仍然需要在起任务前提前创建好

相关文章:

  • 北京网站建设多少钱?
  • 辽宁网页制作哪家好_网站建设
  • 高端品牌网站建设_汉中网站制作
  • docker 学习笔记
  • 初识爬虫1
  • 数据结构————栈的讲解(超详细!!!)
  • 基于SpringBoot的租房网站系统
  • AutoDL云计算GPT-SoVITS-TTS语音声色克隆语音合成
  • Rasa: Rasa Core中的相关概念及用法
  • Oracle数据恢复—Oracle数据库误删除表数据如何恢复数据?
  • WPF UpdateSourceTrigger属性
  • 使用 Milvus、vLLM 和 Llama 3.1 搭建 RAG 应用
  • STL和C++11
  • vscode设置vue标签不换行
  • 捕获和处理异常非常重要
  • 使用 C++ 获取系统时间
  • 【EI稳定,马来亚大学主办】2024年计算机与信息安全国际会议(WCCIS 2024,9月27-29)
  • 第67期 | GPTSecurity周报
  • 【node学习】协程
  • 【附node操作实例】redis简明入门系列—字符串类型
  • 【腾讯Bugly干货分享】从0到1打造直播 App
  • download使用浅析
  • java B2B2C 源码多租户电子商城系统-Kafka基本使用介绍
  • js
  • rabbitmq延迟消息示例
  • Redash本地开发环境搭建
  • Spring核心 Bean的高级装配
  • Vue UI框架库开发介绍
  • 创建一个Struts2项目maven 方式
  • 从0到1:PostCSS 插件开发最佳实践
  • 仿天猫超市收藏抛物线动画工具库
  • 分布式熔断降级平台aegis
  • 力扣(LeetCode)56
  • 什么是Javascript函数节流?
  • 事件委托的小应用
  • 验证码识别技术——15分钟带你突破各种复杂不定长验证码
  • 怎么把视频里的音乐提取出来
  • 走向全栈之MongoDB的使用
  • Java总结 - String - 这篇请使劲喷我
  • Mac 上flink的安装与启动
  • 继 XDL 之后,阿里妈妈开源大规模分布式图表征学习框架 Euler ...
  • #NOIP 2014#Day.2 T3 解方程
  • #QT(一种朴素的计算器实现方法)
  • (4)(4.6) Triducer
  • (delphi11最新学习资料) Object Pascal 学习笔记---第13章第6节 (嵌套的Finally代码块)
  • (floyd+补集) poj 3275
  • (Pytorch框架)神经网络输出维度调试,做出我们自己的网络来!!(详细教程~)
  • (Redis使用系列) SpringBoot中Redis的RedisConfig 二
  • (ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY)讲解
  • (二)原生js案例之数码时钟计时
  • (二十九)STL map容器(映射)与STL pair容器(值对)
  • (附源码)springboot 基于HTML5的个人网页的网站设计与实现 毕业设计 031623
  • (规划)24届春招和25届暑假实习路线准备规划
  • (入门自用)--C++--抽象类--多态原理--虚表--1020
  • * CIL library *(* CIL module *) : error LNK2005: _DllMain@12 already defined in mfcs120u.lib(dllmodu
  • ***监测系统的构建(chkrootkit )
  • .Net - 类的介绍
  • .net MVC中使用angularJs刷新页面数据列表