> 文章列表 > Debezium系列之:自定义表级别Topic的名称

Debezium系列之:自定义表级别Topic的名称

Debezium系列之:自定义表级别Topic的名称

Debezium系列之:自定义表级别Topic的名称

  • 一、需求背景
  • 二、去掉部分topic名称的方法
  • 三、debezium具体实现方法
  • 四、完整配置

一、需求背景

  • debezium表级别Topic命名规则为:topic.prefix参数的值.数据库名称.表的名称
  • 现在支持实时需求,命名名称需要修改为topic.prefix参数的值.表的名称

实现的效果如下所示:
Debezium系列之:自定义表级别Topic的名称

二、去掉部分topic名称的方法

\"transforms=RemoveString\",
\"transforms.RemoveString.type\": \"org.apache.kafka.connect.transforms.RegexRouter\",
\"transforms.RemoveString.regex\"<