基于Canal和Kafka实现MySQL的Binlog近实时同步

前提 近段时间，业务系统架构基本完备，数据层面的建设比较薄弱，由于笔者目前工做重心在于搭建一个小型的数据平台。优先级比较高的一个任务就是须要近实时同步业务系统的数据（包括保存、更新或者软删除）到一个另外一个数据源，持久化以前须要清洗数据而且构建一个相对合理的便于后续业务数据统计、标签系统构建等扩展功能的数据模型。基于当前团队的资源和能力，优先调研了Alibaba开源中间件Canal的使用。java

>>阅读原文<<