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"