使用Canal + Kafka + ElasticSearch记录数据库修改历史

0

最近有个需求需要记录某些数据库表里面的新增修改和删除日志。
开始本来想直接通过注解方式实现,但是后来看了看,实现起来比较麻烦。主要是批量修改的时候很难记录日志。
所以想到使用Canal来监听MySQL的binlog,然后发送修改到Kafka,然后入库到ElasticSearch。

DEMO地址:https://gitee.com/acgist/muses/tree/master/service-parent/service-log-parent