This is an automated email from the ASF dual-hosted git repository.
vongosling pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git.
from 1aa2355 Update README.md
new 1f106d7 feat(pull_consumer) refactor the consumer offset update logic
new 94dc0e0 feat(pull_consumer) refactor the consumer offset update logic
new ad149dd chore(pull_consumer) simplify the lite pull consumer update
offset logic
new 366e6e7 Merge pull request #1705 from duhenglucky/pull_consumer_offset
The 1296 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../client/consumer/DefaultLitePullConsumer.java | 2 +-
.../client/impl/consumer/AssignedMessageQueue.java | 4 +++
.../impl/consumer/DefaultLitePullConsumerImpl.java | 38 ++++++----------------
3 files changed, 15 insertions(+), 29 deletions(-)