sql >> Databasteknik >  >> RDS >> Mysql

Är det möjligt i Debezium att konfigurera tabellnamn => kafka-ämnesmappning?

Ja, använd Single Message Transforms , enligt länken du identifierade. Du kan använda reguljära uttryck (regex) för att mappa tabellerna till det ämne som krävs. Båda io.debezium.transforms.ByLogicalTableRouter eller org.apache.kafka.connect.transforms.RegexRouter borde göra susen. Det finns ett exempel på det senare i detta inlägg här :

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



  1. Hur kan jag göra fatala fel av ALLA mysql-varningar?

  2. Återgå till traditionell replikering från GTID

  3. Använda INSERT INTO från SQL Server för att ändra Salesforce-data

  4. ändra format datum MySql