RocketMQ源码分析之拉取消息(3)

心跳发送完毕后获取broker对应的版本,组装更新消费偏移量请求头UpdateConsumerOffsetRequestHeader,请求码是UPDATE_CONSUMER_OFFSET = 15java public void updateConsumerOffsetOneway( final String addr, final UpdateConsumerOffsetRequ
相关文章
相关标签/搜索