Debezium系列之:同一张表的数据始终进入Kafka Topic的相同分区,同时表结构变化的DDL事件也发送到相同分区 一、需求背景二、实现思路三、核心参数和参数详解四、创建表五、提交Debezium Connector六、插入数据,并消费Topic七、修改表结构,消费Topic八、再次插入数据,消费Topic九、总结和延展 一、需求背景 多张表的数据分发到同一个Kafka Topic需要相同表的数据始终进入Kafka Topic的相同分区,当表的表结构发生变化时,需要把ddl事件也发送到数据对应的Kafka Topic分区中。 可以参考博主以下技术博客,了解到使用的相关技术: