Canal订阅binlog变更并结合kafka实现消息缓冲

Posted barrywxx

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Canal订阅binlog变更并结合kafka实现消息缓冲相关的知识,希望对你有一定的参考价值。

阿里Canal项目请先了解:canal

考虑可能binlog大批量变更,如果直接通过Canal订阅binlog变动,会造成CanaClient会瞬间爆掉。为了解决这个问题,我们可以引入kafka做一层封装,可以解决这个问题。

未完待续。。。。。。

以上是关于Canal订阅binlog变更并结合kafka实现消息缓冲的主要内容,如果未能解决你的问题,请参考以下文章

canal1.1.5 配置kafka

canal+Kafka实现mysql与redis数据同步

Canal利用canal实现mysql实时增量备份并对接kafka

监听MySQL的binlog日志工具分析:Canal

基于Canal和Kafka实现MySQL的Binlog近实时同步

canal入门