Ya, gunakan Transformasi Pesan Tunggal
, per tautan
Anda mengidentifikasi. Anda dapat menggunakan ekspresi reguler (regex) untuk memetakan tabel ke topik yang diperlukan. Keduanya io.debezium.transforms.ByLogicalTableRouter atau org.apache.kafka.connect.transforms.RegexRouter harus melakukan trik. Ada contoh yang terakhir di pos ini di sini
:
"transforms":"dropPrefix",
"transforms.dropPrefix.type":"org.apache.kafka.connect.transforms.RegexRouter",
"transforms.dropPrefix.regex":"DC1-TEST-(.*)",
"transforms.dropPrefix.replacement":"$1"