RocketMQ 位移提交源码分析

向你们提个问题：javascript RocketMQ 消息消费进度是如何提交的，并发消费的时候，一次从 一个队列拉 32 条消息，这 32 条消息会提交到线程池中处理，若是偏移量  m5 比 m4 先执行完成，消息消费后，提交的消费进度是哪一个？是提交消息 m5 的偏移量？java 下面跟着个人节奏，撸一波源码。apache RocketMQ 每次拉取完消息都会将消息存储到 PullReques

>>阅读原文<<