RocketMQ原理(4)——消息ACK机制及消费进度管理

https://zhuanlan.zhihu.com/p/25265380java consumer的每一个实例是靠队列分配来决定如何消费消息的。那么消费进度具体是如何管理的,又是如何保证消息成功消费的(RocketMQ有保证消息确定消费成功的特性(失败则重试)?数据库 本文将详细解析消息具体是如何ack的,又是如何保证消费确定成功的。缓存 因为以上工做全部的机制都实如今PushConsumer中
相关文章
相关标签/搜索