Ja, verwenden Sie Single Message Transforms
, per dem Link
du hast dich identifiziert. Sie können reguläre Ausdrücke (Regex) verwenden, um die Tabellen dem gewünschten Thema zuzuordnen. Sowohl io.debezium.transforms.ByLogicalTableRouter oder org.apache.kafka.connect.transforms.RegexRouter sollte den Trick machen. Es gibt ein Beispiel für letzteres in diesem Beitrag hier
:
"transforms":"dropPrefix",
"transforms.dropPrefix.type":"org.apache.kafka.connect.transforms.RegexRouter",
"transforms.dropPrefix.regex":"DC1-TEST-(.*)",
"transforms.dropPrefix.replacement":"$1"