Debezium系列之：把多张表的数据分发到同一个Kafka Topic，同一张表的数据始终进入Topic相同分区
Debezium系列之：把多张表的数据分发到同一个Kafka Topic，同一张表的数据始终进入Topic相同分区
- 一、需求背景
- 二、实现思路
- 三、核心参数和参数详解
- 四、创建相关表
- 五、提交Debezium Connector
- 六、插入数据
- 七、消费Kafka Topic
- 八、总结和延展
一、需求背景
- debezium采集数据库的多张表，一般是一张表对应一个Kafka Topic，现在想把多张表的数据分发到一个多分区的Kafka Topic
- 最重要的是要保证相同表的数据始终出现在topic的相同分区，比如product表的数据始终发往分区0，order表的数据始终发往分区3
可以参考博主以下技术博客，了解使用到的相关技术：