GitHub user wpy0032 edited a discussion: rocketmq5.2使用controller下whichBrokerWhenConsumeSlowly=1是指的brokerid=1还是代指从服务器
rocketmq5.2当消息消费者向从服务器拉取消息后,会一直从从服务器拉取? 1)如果从服务器的slaveReadEnable设置为false,则下次拉取,从主服务器拉取。 2)如果从服务器允许读取并且从服务器积压的消息未超过其物理内存的40%,下次拉取使用的Broker为订阅组的brokerId指定的Broker服务器,该值默认为0,代表主服务器。 3)如果从服务器允许读取并且从服务器积压的消息超过了其物理内存的40%,下次拉取使用的Broker为订阅组的whichBrokerWhenConsumeSlowly指定的Broker服务器,该值默认为1。 当我不是采用普通的M-S架构,使用的controller来管理的M-S,controller分配的slave的BrokerId可能>1,whichBrokerWhenConsumeSlowly默认的是1,第3)点的whichBrokerWhenConsumeSlowly是如何选择的呢?是只能从brokerid=1的从服务器拉取消息,还是whichBrokerWhenConsumeSlowly=1代表的是从服务器,不管其BrokerId是多少? GitHub link: https://github.com/apache/rocketmq/discussions/8330 ---- This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org