Debezium系列之:实现表中指定字段相同的数据始终发往Kafka Topic相同的分区
创始人
2024-03-02 14:21:56
0次
Debezium系列之:实现表中指定字段相同的数据始终发往Kafka Topic相同的分区
- 一、需求背景
- 二、相关技术博客
- 三、技术实现
- 四、创建表
- 五、提交connector
- 六、插入数据
- 七、消费topic
一、需求背景
- 一张表中指定字段相同的数据,始终发往Kafka Topic相同的分区
二、相关技术博客
- Debezium系列之:联合主键数据发往kafka topic相同分区
- Debezium系列之:相同主键数据进入相同分区
三、技术实现
- “database.include.list”: “dw”,
- “table.include.list”: “dw.retail_order_detail”,
- “message.key.columns”: “dw.retail_order_detail:cdc_code,product,price”,
参数详解
相关内容