はい、シングルメッセージ変換
を使用してください 、リンク
ごと あなたが特定した。正規表現(regex)を使用して、テーブルを必要なトピックにマップできます。両方のio.debezium.transforms.ByLogicalTableRouter
またはorg.apache.kafka.connect.transforms.RegexRouter
トリックを行う必要があります。後者の例があります
"transforms":"dropPrefix",
"transforms.dropPrefix.type":"org.apache.kafka.connect.transforms.RegexRouter",
"transforms.dropPrefix.regex":"DC1-TEST-(.*)",
"transforms.dropPrefix.replacement":"$1"