一、需求背景
- 业务同步数据库数据到kafka topic，下游消费kafka topic到另外的数据库，源数据库部分表结构变化比较频繁，希望数据库的ddl和dml数据能够发往同一个kafka topic，当获取到ddl数据时，就自动修改目标数据库表结构，再处理后续的dml数据
二、实现方案
- 需要保证顺序一致性，kafka topic可以采用单分区
- 基于SMT实现把存储ddl数据的topic和存储dml数据的topic中的数据都发往同一个Kafka topic
三、参数详解
详细了解SMT技术博客如下所示：