ozw999 opened a new issue #4016: URL: https://github.com/apache/rocketmq/issues/4016
# 前提 一个3主的MQ集群（broker-a/b/c），业务和MQ在同一台。consumer使用broadcasting模式 和 ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET，topic的在三台上都有queue。 # 问题 将broker-a所在的服务器断网，此时三个consumer分别触发rebalance。`org.apache.rocketmq.client.impl.consumer.RebalanceImpl.updateProcessQueueTableInRebalance()` 方法将consumer-a中的broker-b和broker-c的offset都清除了。导致将服务器网络恢复后，在断网期间产生在broker-a和broker-b上的message未被消费。 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
