Ja, gebruik Single Message Transforms
, per de link
jij identificeerde. U kunt reguliere expressies (regex) gebruiken om de tabellen toe te wijzen aan het gewenste onderwerp. Beide io.debezium.transforms.ByLogicalTableRouter of org.apache.kafka.connect.transforms.RegexRouter zou moeten lukken. Er is een voorbeeld van het laatste in dit bericht hier
:
"transforms":"dropPrefix",
"transforms.dropPrefix.type":"org.apache.kafka.connect.transforms.RegexRouter",
"transforms.dropPrefix.regex":"DC1-TEST-(.*)",
"transforms.dropPrefix.replacement":"$1"