阿里Canal项目请先了解：canal
考虑可能binlog大批量变更，如果直接通过Canal订阅binlog变动，会造成CanaClient会瞬间爆掉。为了解决这个问题，我们可以引入kafka做一层封装，可以解决这个问题。
未完待续。。。。。。
Canal订阅binlog变更并结合kafka实现消息缓冲
原文：https://www.cnblogs.com/barrywxx/p/10850675.html
