Tak, użyj przekształceń pojedynczego komunikatu
, za link
zidentyfikowałeś. Możesz użyć wyrażeń regularnych (regex), aby odwzorować tabele na wymagany temat. Oba io.debezium.transforms.ByLogicalTableRouter
lub org.apache.kafka.connect.transforms.RegexRouter
powinien załatwić sprawę. Oto przykład tego ostatniego w tym poście tutaj
:
"transforms":"dropPrefix",
"transforms.dropPrefix.type":"org.apache.kafka.connect.transforms.RegexRouter",
"transforms.dropPrefix.regex":"DC1-TEST-(.*)",
"transforms.dropPrefix.replacement":"$1"