flink-cdc
flink-cdc copied to clipboard
[FLINK-38779] Route module supports standard RegExp replacement rules
This closes FLINK-38779.
CDC Pipeline router supports simple table name replacement for now. A route rule like this:
- { source-table: 'db.\\.*', sink-table: 'new_db.<>', replace-symbol: '<>' }
synchronizes all tables in db to new_db.
More complicated routing rules, including re-mapping database and schema name, or capturing parts of identifiers, is not possible.
Current API could be extended to support standard RegEx capturing & replacement syntaxes like this:
- { source-table: 'db.(\\.*)', sink-table: 'new_db.$1' }
and keep backwards compatiblility.
TableIdRouter has been moved to flink-cdc-common as a Public API.
Blocked by #4187.