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

Question

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

Answer 1

是的，使用Single Message Transforms ，每 the link你确定了。您可以使用正则表达式 (regex) 将表映射到所需的主题。 io.debezium.transforms.ByLogicalTableRouter 或 org.apache.kafka.connect.transforms.RegexRouter 都应该可以解决问题。有后者的一个例子 in this post here :

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