是否可以在 Debezium 中配置 table_name => kafka 主题映射？

Question

我已经阅读了 http://debezium.io/docs/connectors/mysql/但我找不到有关是否可以配置 debezium 以便可以将 2 个（或更多）表中的更改写入相同的单个 kafka 主题的任何信息？在我看来，它总是 1 张桌子 -> 1 个主题。

Answer 1

是的，根据您确定的链接使用单消息转换。您可以使用正则表达式 （regex） 将表映射到所需的主题。io.debezium.transforms.ByLogicalTableRouter或org.apache.kafka.connect.transforms.RegexRouter都应该做到这一点。这篇文章中有后者的例子：

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