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

Question

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

Answer 1

是的，根据您确定的链接使用Single Message Transforms 。您可以使用正则表达式 (regex) 将表映射到所需的主题。两者或应该做的伎俩。在这篇文章中有一个后者的例子：io.debezium.transforms.ByLogicalTableRouterorg.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"