我读过http://debezium.io/docs/connectors/mysql/ 但是我找不到任何关于是否可以配置debezium的信息，以便将2个（或更多）表中的更改写入同一个kafka主题？在我看来，它总是一个表->一个主题。
htrmnn0y1#
是的，根据您标识的链接使用单个消息转换。可以使用正则表达式（regex）将表Map到所需的主题。两者 io.debezium.transforms.ByLogicalTableRouter 或者 org.apache.kafka.connect.transforms.RegexRouter 应该会成功的。这篇文章中有一个后者的例子：
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"
1条答案
按热度按时间htrmnn0y1#
是的，根据您标识的链接使用单个消息转换。可以使用正则表达式（regex）将表Map到所需的主题。两者
io.debezium.transforms.ByLogicalTableRouter或者org.apache.kafka.connect.transforms.RegexRouter应该会成功的。这篇文章中有一个后者的例子：