debezium主题路由3表

Question

我有3种表格类型

raw_app_logs_$daystamp
raw_users_logs_$daystamp
city_logs_$daystamp

现在，以下主题Reroute适用于1表类型：

transforms=Reroute
transforms.Reroute.type=io.debezium.transforms.ByLogicalTableRouter
transforms.Reroute.topic.regex=(.*)raw_app_logs(.*)
transforms.Reroute.topic.replacement=$1raw_app_logs

这采用了raw_app_logs_20200720、raw_app_logs_20200721等，并将其很好地写入了raw_app_logs主题。

我如何添加另外两个条目，使它们匹配并发送到它们的主题名称？

例如:在同一个配置文件中，raw_app_logs_20200720转到主题raw_app_logs，而raw_users_logs_20200720转到名为raw_users_logs的主题，city_logs_20200720转到名为city_logs的主题。

Answer 1

找到了答案：

使用regex组，然后只打印第一个组：

transforms=Reroute
transforms.Reroute.type=io.debezium.transforms.ByLogicalTableRouter
transforms.Reroute.topic.regex=(.*)([^0-9]).*
transforms.Reroute.topic.replacement=$1