rocketmq-client-cpp icon indicating copy to clipboard operation
rocketmq-client-cpp copied to clipboard
verified publisher icon apache

[ISSUE #481]Fixed the issue that reset location cannot be consumed immediately

Open humkum opened this issue 1 year ago • 1 comments

fix #481

Root cause of the problem：

  1. The consumer would set all exist pull request as dropped and do rebalance after change the local offset and the broker's consumption offset. image
  2. But the pull request was not removed from the cache in RebalanceImp.cpp
  3. When doRebalance immediately after reset offset success, the new pull request can not assign to target message queues, which should be consumed by the client.

image

humkum avatar Dec 04 '24 02:12 humkum

@ShannonDing @ifplusor Could you please help to review this pr?

humkum avatar Dec 19 '24 12:12 humkum