这个问题在这里已经有了答案：
在debezium中是否可以配置表\u name=>kafka主题Map(1个答案）两年前关门了。如何配置debezium将数据库中的所有表发布到单个kafka主题？有可能吗？
k5hmc34c1#
默认情况下，debezium为每个数据库+表写出一个主题不过，您可能需要查看有关主题路由的文档debezium使您能够在消息到达转换器之前使用单个消息转换（smt）重新路由发出的更改。debezium提供的smt使您能够根据正则表达式和替换模式重写主题和密钥，每个debezium示例都可以配置。所以你可以试试
transforms=Combine transforms.Combine.type=io.debezium.transforms.ByLogicalTableRouter transforms.Combine.topic.regex=(.*) transforms.Combine.topic.replacement=all_tables
在kafka connect文档部分还可以找到其他smt示例，我认为regexrouter是一个值得尝试的示例
1条答案
按热度按时间k5hmc34c1#
默认情况下，debezium为每个数据库+表写出一个主题
不过，您可能需要查看有关主题路由的文档
debezium使您能够在消息到达转换器之前使用单个消息转换（smt）重新路由发出的更改。debezium提供的smt使您能够根据正则表达式和替换模式重写主题和密钥，每个debezium示例都可以配置。
所以你可以试试
在kafka connect文档部分还可以找到其他smt示例，我认为regexrouter是一个值得尝试的示例