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

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

>>阅读原文<<