Debezium系列之：把多个数据库中多张表的数据发送到一个Kafka topic中

Posted 2022-05-16 目标博客专家

Debezium系列之：把多个数据库中多张表的数据发送到一个Kafka topic中

• 一、Debezium专栏博客每周更新计划
• 二、需求描述
• 三、参数设置
• 四、提交debezium connector参数示例

一、Debezium专栏博客每周更新计划

后续每周在日常更新Debezium技术文章的同时，会以一定频率同步更新Debezium源码阅读系列文章，欢迎与博主交流Debezium相关技术，一起加油。

二、需求描述

需求1:

• 需要把一个数据库中的多张表的数据，全部导入同一个kafka topic中

需求2:

• 把多个数据库中多张表的数据发送到一个Kafka topic中

三、参数设置

提交debezium connector需要增加以下参数，才能实现需求1和需求2：

参数1:“transforms”:“Reroute”

参数说明：

• “transforms”:“Reroute” 默认设置

参数2:“transforms.Reroute.type”:“io.debezium.transforms.ByLogicalTableRouter”

参数说明：

• “transforms.Re