Debezium系列之：基于内容路由实现把数据库表中的数据按照数据类型分发到不同的topic
Debezium系列之：基于内容路由实现把数据库表中的数据按照数据类型分发到不同的topic
- 一、需求背景
- 二、创建表
- 三、插入、更新、删除数据
- 四、核心参数和实现技术
- 五、查看分发的Topic
- 六、消费Topic数据
- 七、总结和延展
一、需求背景
- 一张表中存有各个超市门店的订单信息，例如超市门店1、超市门店2、超市门店3，现在希望超市门店1的订单数据发送到topic1，超市门店2的订单数据发送到topic2，超市门店3的订单数据发送到topic3
- 难点在于超市门店1的增删改数据都要发送到topic1,超市门店2的增删改数据都要发送到topic2,超市门店3的增删改数据都要发送到topic3
二、创建表
CREATE TABLE dw.address (`id` bigint(<