上海网站设计大连,甜品网站设计,提升学历报名入口,写作网站哪个好用新增优点#xff1a;Pattern Replacement in routing rules
flinkcdc 3.2.0版本相较于3.1.0版本#xff0c;避免了多表多sink多次写 route 路由的麻烦#xff0c;类似于统一前后缀的形式多表多sink#xff0c;通过正则#xff0c;大大减少了书写
官网#xff1…新增优点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_dbThen, 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: 1adb会根据route路由规则进行整库同步bdb则会根据默认的无路由规则进行整库同步。
数据库仍然需要在起任务前提前创建好
