7
Canal EventStore 目前只实现了内存队列,能否支持扩展出Kafka、RocketMQ等消息队列?
https://github.com/alibaba/canal/wiki/DevGuide
Canal EventStore 目前只实现了内存队列,能否支持扩展出Kafka、RocketMQ等消息队列?
https://github.com/alibaba/canal/wiki/DevGuide
内存操作速度快,再绕一次kafka太影响效率了
我们有一个业务场景是,binlog被清理后,可以根据MQ来回放
canal可以将binlog投递到kafka后,基于kafka的client生态来继续消费binlog