[FLINK-35647] Pipeline route rule supports placeholder replacement

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Implemented
• Affects Version/s: cdc-3.1.1
• Fix Version/s: cdc-3.2.0
• Component/s: Flink CDC
• Labels: pull-request-available
• Assignee: yux
• Reporter: yux
• Created: 19/Jun/24 05:58
• Updated: 12/Jul/24 09:40
• Resolved: 12/Jul/24 09:36

Description

Currently, we must provide explicit sink-table in pipeline route rules, which means if we'd like to route all tables in specific database and change names in pattern, there's no choice but write all rules separately, which is a chore.

There's already an implementation (https://github.com/apache/flink-cdc/pull/2908) to use some placeholder syntax like (db.source<> -> db.sink<>) to perform replacement in batch, which could solve this problem.

Issue Links

• links to: GitHub Pull Request #3428