Ano, použít Transformace jedné zprávy
podle odkazu
identifikovali jste. K mapování tabulek na požadované téma můžete použít regulární výrazy (regex). Oba io.debezium.transforms.ByLogicalTableRouter
nebo org.apache.kafka.connect.transforms.RegexRouter
by měl udělat trik. Zde je příklad druhého v tomto příspěvku zde
:
"transforms":"dropPrefix",
"transforms.dropPrefix.type":"org.apache.kafka.connect.transforms.RegexRouter",
"transforms.dropPrefix.regex":"DC1-TEST-(.*)",
"transforms.dropPrefix.replacement":"$1"