Skip to content

Conversation

@yuxiqian
Copy link
Member

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.

@github-actions github-actions bot added docs Improvements or additions to documentation common runtime mysql-pipeline-connector labels Dec 10, 2025
@yuxiqian
Copy link
Member Author

Blocked by #4187.

@yuxiqian yuxiqian marked this pull request as draft December 10, 2025 09:55
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

common docs Improvements or additions to documentation mysql-pipeline-connector runtime

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant