paimon
paimon copied to clipboard
[Feature] [cdc] Support merge_shards in kafka/pulsar database synchronization
Search before asking
- [X] I searched in the issues and found nothing similar.
Motivation
binlog data in the same topic may contain data with the same table name in different database. Provide the merge_shards parameter like Mysql-cdc to avoid table name conflicts.
Solution
No response
Anything else?
No response
Are you willing to submit a PR?
- [X] I'm willing to submit a PR!