撸了个小轮子,将 Binlog 解析成 json 推送 kafka

https://github.com/feiin/go-binlog-kafka

将 binlog 解析成 json 并推送 kafka 方便订阅消费

{ "binlog_file": "mysql-bin.000052", // binlog file "log_pos": 3013167, // binlog position "action": "insert", // insert/update/delete/DDL action "table": "tests", // 表名称 "gtid": "68414ab6-fd2a-11ed-9e2d-0242ac110002:1-608",// GTID "schema": "tests", // 库名称 "values": null, // insert/delete 时是对应行数据 "before_values":{...} // update 变更前行数据 "after_values":{...} // update 变更后行数据 }