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"