apache / rocketmq

Apache RocketMQ is a cloud native messaging and streaming platform, making it simple to build event-driven applications.
https://rocketmq.apache.org/
Apache License 2.0
21.26k stars 11.7k forks source link

[Bug] Network jitter encountered while rebalancing results in repeated consumption or errors in pop mode #8686

Open 3424672656 opened 2 months ago

3424672656 commented 2 months ago

Before Creating the Bug Report

Runtime platform environment

centos

RocketMQ version

develop

JDK Version

1.8

Describe the Bug

When pop consumption mode is enabled for topic-a, the client sets isRebanlance=false 293b0204-1fda-4d5f-80f1-14042da21dc2 1501d98d-a6d2-4ca3-86dd-aedc51d70e3e 39ae3686-1817-4c6a-855b-20ab8f7723b6 5f8f2576-dd0b-4b52-92d4-b4dbdb78aecd Client rebalancing does not make pop consumption pattern judgment

Steps to Reproduce

The setMessageRequestMode interface of MQAdmin is called, the broker is network isolated from the client, the client is set isRebanlance=false, the network is restored after some time, and it is found that there is no pop consumption on the topic

What Did You Expect to See?

Topics are consumed in pop mode

What Did You See Instead?

Topics are not consumed in pop mode

Additional Context

No response