rocketMq - 并发消费过程

rocketMq消费过程包括两种,分别是并发消费和有序消费,每个消费方式都可以单独拿出来进行分享,这篇文章单独用来分析并发消费问题。 并发消费需要理解的几个核心点:并发消费的消息拉取,并发消费的消息重试,并发消息的ack机制,消费进度的持久化,这篇分享会就这几个问题分解展开。 其他逻辑     1、consumer会定期向broker同步ack消息偏移量,也就是已经消费的位置。     2、极端情
相关文章
相关标签/搜索