RocketMQ源碼分析之拉取消息（3）

心跳發送完畢後獲取broker對應的版本，組裝更新消費偏移量請求頭UpdateConsumerOffsetRequestHeader，請求碼是UPDATE_CONSUMER_OFFSET = 15java public void updateConsumerOffsetOneway( final String addr, final UpdateConsumerOffsetRequ

>>阅读原文<<