基於Canal和Kafka實現MySQL的Binlog近實時同步

前提 近段時間，業務系統架構基本完備，數據層面的建設比較薄弱，由於筆者目前工做重心在於搭建一個小型的數據平臺。優先級比較高的一個任務就是須要近實時同步業務系統的數據（包括保存、更新或者軟刪除）到一個另外一個數據源，持久化以前須要清洗數據而且構建一個相對合理的便於後續業務數據統計、標籤系統構建等擴展功能的數據模型。基於當前團隊的資源和能力，優先調研了Alibaba開源中間件Canal的使用。java

>>阅读原文<<