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"