当前位置: 首页 > 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则会根据默认的无路由规则进行整库同步。

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

http://www.lryc.cn/news/435838.html

相关文章:

  • 《 C++ 修炼全景指南:六 》深入探索 C++ 标准库中的 stack 与 queue 容器适配器
  • 高级java每日一道面试题-2024年9月07日-JVM篇-说一下类加载的执行过程?
  • 笔试强训day09
  • 软件测试中的黑盒测试方法,包括其定义、目的及主要步骤。
  • Shell脚本计算π的近似值
  • 进程间通信之消息队列
  • 人生苦短我用Python 5-xlwings自动调整表格
  • 移动跨平台框架Flutter详细介绍和学习线路分享
  • 线性代数基础:向量、矩阵、张量及其在机器学习中的应用详解
  • Dockerfile中的RUN、CMD、ENTRYPOINT指令区别
  • css grid布局属性详解
  • Tranformer分布式特辑
  • 【Moveit2官方教程】使用 MoveIt Task Constructor (MTC) 框架来定义和执行一个机器人任务
  • 使用docker配置wordpress
  • JVM字节码
  • python访问mysql
  • Java工具插件
  • Class3——Esp32|Thonny——网络连接主机-wifi连接(源代码带教程)
  • 特效【生日视频制作】小车汽车黄金色版悍马车身AE模板修改文字软件生成器教程特效素材【AE模板】
  • 如何利用Java进行快速的足球大小球及亚盘数据处理与分析
  • 代码随想录打卡Day29
  • 图分类!!!
  • 高防IP是如何防御攻击
  • Kubernetes 系列 | k8s入门运维
  • yolov8+deepsort+botsort+bytetrack车辆检测和测速系统
  • 基于准静态自适应环型缓存器(QSARC)的taskBus万兆吞吐实现
  • C++笔记---指针常量和常量指针
  • Python习题 177:设计银行账户类并实现存取款功能
  • IPhone 16:它的 “苹果智能 “包括哪些内容?
  • 【中国国际航空-注册/登录安全分析报告】