Canal订阅binlog变更并结合kafka实现消息缓冲
Posted barrywxx
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Canal订阅binlog变更并结合kafka实现消息缓冲相关的知识,希望对你有一定的参考价值。
阿里Canal项目请先了解:canal
考虑可能binlog大批量变更,如果直接通过Canal订阅binlog变动,会造成CanaClient会瞬间爆掉。为了解决这个问题,我们可以引入kafka做一层封装,可以解决这个问题。
未完待续。。。。。。
以上是关于Canal订阅binlog变更并结合kafka实现消息缓冲的主要内容,如果未能解决你的问题,请参考以下文章
Canal利用canal实现mysql实时增量备份并对接kafka