RocketMQ 位移提交源码分析

[objcoding]

https://objcoding.com/2019/11/04/rocketmq-offsets/

向大家提个问题：RocketMQ 消息消费进度是如何提交的，并发消费的时候，一次从 一个队列拉 32 条消息，这 32 条消息会提交到线程池中处理，如果偏移量 m5 比 m4 先执行完成，消息消费后，提交的消费进度是哪个？是提交消息m5的偏移量？下面跟着我的节奏，撸一波源码。