sql >> Database teknologi >  >> RDS >> Mysql

Er det muligt i Debezium at konfigurere tabelnavn => kafka emnemapping?

Ja, brug Single Message Transforms , ifølge linket du identificerede. Du kan bruge regulære udtryk (regex) til at knytte tabellerne til det ønskede emne. Begge io.debezium.transforms.ByLogicalTableRouter eller org.apache.kafka.connect.transforms.RegexRouter burde gøre tricket. Der er et eksempel på sidstnævnte i dette indlæg her :

"transforms":"dropPrefix",  
"transforms.dropPrefix.type":"org.apache.kafka.connect.transforms.RegexRouter",  
"transforms.dropPrefix.regex":"DC1-TEST-(.*)",  
"transforms.dropPrefix.replacement":"$1"



  1. T-sql - afgør om værdien er heltal

  2. Sådan udskrives en MySQL-databasetabel i PHP ved hjælp af PDO

  3. Opsætning af en geo-distribueret databaseklynge ved hjælp af MySQL-replikering

  4. SIGN() Funktion i Oracle