Sì, usa Trasformazioni a messaggio singolo
, per il link
ti sei identificato. È possibile utilizzare le espressioni regolari (regex) per eseguire il mapping delle tabelle all'argomento richiesto. Entrambi io.debezium.transforms.ByLogicalTableRouter o org.apache.kafka.connect.transforms.RegexRouter dovrebbe fare il trucco. C'è un esempio di quest'ultimo in questo post qui
:
"transforms":"dropPrefix",
"transforms.dropPrefix.type":"org.apache.kafka.connect.transforms.RegexRouter",
"transforms.dropPrefix.regex":"DC1-TEST-(.*)",
"transforms.dropPrefix.replacement":"$1"
