flink-cdc icon indicating copy to clipboard operation
flink-cdc copied to clipboard

[FLINK-38779] Route module supports standard RegExp replacement rules

Open yuxiqian opened this issue 3 months ago • 1 comments

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.

yuxiqian avatar Dec 10 '25 09:12 yuxiqian

Blocked by #4187.

yuxiqian avatar Dec 10 '25 09:12 yuxiqian