从PullRequest对象中获取ProcessQueue中,并更新ProcessQueue的最后更新时间为当前时间
进行消息拉取流控,主要包括两方面: 如果ProcessQueue当前的消息条数超过了...关于该队列的下一次拉取任务延迟3s
与服务端交互: 从哪个消费队列拉取?...默认情况下消息消费者从master拉取,当master积压的消息超过了物理内存的40%,则建议从slave拉取....设置为false,则下次拉取从master拉取
如果slave允许读取并且slave积压的消息未超过其物理内存的40%,下次拉取使用的Broker为订阅组的brokerId指定的Broker服务器,该值默认为...服务器,该值默认为1,代表slave
主从服务消息消费进是如何同步的
消息消费进度的同步时单向的,slave开启一个定时任务,定时从master同步消息消费进度
无论消息消费者是从master拉的消息还是从