RocketMQ 位移提交源碼分析

向你們提個問題：javascript RocketMQ 消息消費進度是如何提交的，併發消費的時候，一次從 一個隊列拉 32 條消息，這 32 條消息會提交到線程池中處理，若是偏移量  m5 比 m4 先執行完成，消息消費後，提交的消費進度是哪一個？是提交消息 m5 的偏移量？java 下面跟着個人節奏，擼一波源碼。apache RocketMQ 每次拉取完消息都會將消息存儲到 PullReques

>>阅读原文<<