Cczzzz opened a new issue, #4206:
URL: https://github.com/apache/rocketmq/issues/4206
After resetOffset, whether the offset will be modified if there is a
response from the previous request. Let resetOffset not take effect。
DefaultMQPushConsumerImpl#361
case NO_NEW_MSG:
case NO_MATCHED_MSG:
pullRequest.setNextOffset(pullResult.getNextBeginOffset());
DefaultMQPushConsumerImpl.this.correctTagsOffset(pullRequest);
DefaultMQPushConsumerImpl.this.executePullRequestImmediately(pullRequest);
offset will be overwritten？
--
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]
