Mysql
 sql >> Datenbank >  >> RDS >> Mysql

Ist es in Debezium möglich, table_name => kafka Topic Mapping zu konfigurieren?

Ja, verwenden Sie Single Message Transforms , per dem Link du hast dich identifiziert. Sie können reguläre Ausdrücke (Regex) verwenden, um die Tabellen dem gewünschten Thema zuzuordnen. Sowohl io.debezium.transforms.ByLogicalTableRouter oder org.apache.kafka.connect.transforms.RegexRouter sollte den Trick machen. Es gibt ein Beispiel für letzteres in diesem Beitrag hier :

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