regex 在Debezium中,是否有一种方法可以将表路由到不同的主题?

bnl4lu3b  于 2023-01-18  发布在  其他
关注(0)|答案(1)|浏览(104)

我的table:
1.用户
1.客户
1.通知
1.警报
默认情况下,我希望信息转到主题user_service.$tableName,但对于特定的表,我希望信息在不同的表中。
预期输出
1.用户=〉用户服务.用户
1.客户端=〉用户服务.客户端
1.通知=〉通知服务.通知
1.警报=〉警报服务. alerts
我的配置适用于一个表(如通知),但不确定如何针对多个表进行调整
现有配置:

"transforms": "unwrap,Reroute",
"transforms.Reroute.type": "io.debezium.transforms.ByLogicalTableRouter",
"transforms.Reroute.topic.regex": "(.*)notifications",
"transforms.Reroute.topic.replacement": "notificaton_service.notifications",
w1jd8yoj

w1jd8yoj1#

让它和

"transforms": "unwrap,Reroute",
"transforms.Reroute.type": "io.debezium.transforms.ByLogicalTableRouter",
"transforms.Reroute.topic.regex": "(.*)(notifications|alerts)",
"transforms.Reroute.topic.replacement": "$2_service.$2",

相关问题