使用Kettle插件Debezium直接进行MySQL CDC

之前我们使用的Kettle CDC MySQL方案是canal+kafka+kettle，今天我们一起学习下使用kettle的插件Debezium直接cdc mysql。

注：CDC (Change Data Capture) 是一种技术，用于捕获和同步数据库中的更改。

1）Debezium步骤解析mysql binlog日志。

2）json input步骤解析json字符串。

3）switch-case 根据op字段进行路由。

4）create、delete、update、ddl是写日志步骤，模拟后续操作。

Debezium步骤配置如下（只输出dml），更多属性配置参考Debezium官网。如下图所示：

switch-case配置如下，不做过多介绍。

binlog解析之后的dml语句对应的json字符串结构

CREATE

UPDATE

DELETE

Debezium步骤配置中设置ddl为true（输出dml和ddl），更多属性配置参考Debezium官网。如下图所示：

binlog解析之后的ddl语句对应的json字符串结构

DROP TABLE

CREATE TABLE