canal實時抽取mysql數據發送到kafka

基本說明 canal 1.1.1版本以後, 默認支持將canal server接收到的binlog數據直接投遞到MQ, 目前默認支持的MQ系統有:java kafka: https://github.com/apache/kafka RocketMQ : https://github.com/apache/rocketmq   環境版本 操做系統：CentOS release 6.6 (Final

>>阅读原文<<