GitHub user vsair opened a pull request:
ROCKETMQ-175 Consumer may miss messages because of inconsistent sub…
For push mode, update subscription version when rebalance result changed, then send heart beat to broker immediately.
Maybe subscriptions management mechanism could be re-designed to meet more complicated scenarios.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vsair/incubator-rocketmq
Alternatively you can review and apply these changes as the patch at:
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #92
Author: vsair <email@example.com>
ROCKETMQ-175 Consumer may miss messages because of inconsistent subscription
1. For push mode, update subscription version when rebalance result changed.