Ja, brug Single Message Transforms
, ifølge linket
du identificerede. Du kan bruge regulære udtryk (regex) til at knytte tabellerne til det ønskede emne. Begge io.debezium.transforms.ByLogicalTableRouter
eller org.apache.kafka.connect.transforms.RegexRouter
burde gøre tricket. Der er et eksempel på sidstnævnte i dette indlæg her
:
"transforms":"dropPrefix",
"transforms.dropPrefix.type":"org.apache.kafka.connect.transforms.RegexRouter",
"transforms.dropPrefix.regex":"DC1-TEST-(.*)",
"transforms.dropPrefix.replacement":"$1"