debezium 主题路由 3 个表

Question

我有 3 table 种类型

raw_app_logs_$daystamp
raw_users_logs_$daystamp
city_logs_$daystamp

现在以下主题重新路由非常适合 1 table 类型：

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

这需要 raw_app_logs_20200720、raw_app_logs_20200721 等并将其完美地写入 raw_app_logs 主题。

如何添加其他 2 个条目以便将它们匹配并发送到它们的主题名称？

EG：raw_app_logs_20200720 转到主题 raw_app_logs，而 raw_users_logs_20200720 转到名为 raw_users_logs 的主题，city_logs_20200720 转到名为 [=] 的主题20=] 在同一个配置文件中。

Answer 1

找到答案：

使用正则表达式组，然后只打印第一组：

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

debezium 主题路由 3 个表

debezium topic routing 3 tables

regex

debezium