Skip to content

Conversation

humkum
Copy link
Contributor

@humkum humkum commented Dec 4, 2024

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
Copy link
Contributor Author

humkum commented Dec 19, 2024

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

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

[Bug] Reset consume offset then the consumer cannot continue consume immediately
1 participant