經過canal實現把MySQL數據實時增量到kafka

說明：咱們有一個業務須要把mysql中一些表實時同步到大數據集羣hbase上面，咱們先經過sqoop把表中數據全量導入到hbase中，而後再經過canal定位的某個binlog的position，來實現增量同步，canal官網提供了java/go接口，直接寫入到Kafka，而後經過sparkstreaming實時寫入到hbase中html 一. 經過sqoop把mysql表中的數據全量導入到hba

>>阅读原文<<