Debezium系列之:自定义表级别Topic的名称
- 一、需求背景
- 二、去掉部分topic名称的方法
- 三、debezium具体实现方法
- 四、完整配置
一、需求背景
- debezium表级别Topic命名规则为:topic.prefix参数的值.数据库名称.表的名称
- 现在支持实时需求,命名名称需要修改为topic.prefix参数的值.表的名称
实现的效果如下所示:
二、去掉部分topic名称的方法
"transforms=RemoveString",
"transforms.RemoveString.type": "org.apache.kafka.connect.transforms.RegexRouter",
"transforms.RemoveString.regex"<