[rocketmq] branch develop updated (4daf0ee -> cca4d92)

[du...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

duhengforever pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git.


    from 4daf0ee  Merge pull request #2943 from lizhimins/develop
     new 6ab6afd  [ISSUE #2708] Client may submit wrong offset when network instability
     new da589b1  [ISSUE #2708] Client may submit wrong offset when network instability
     new 707d1b8  [ISSUE #2708] Client may submit wrong offset when network instability, add more log
     new 4f7e831  [ISSUE #2708] Fix unit test
     new 96a4e55  [ISSUE #2708] Fix unit test
     new da286a4  [ISSUE #2708] Fix unit test
     new 436d72b  [ISSUE #2708] Fix unit test
     new 9f90a23  [ISSUE #2708] Fix unit test
     new 715a614  [ISSUE #2708] Fix unit test
     new fb34b64  [ISSUE #2708] Reformat
     new c3750b3  [ISSUE #2708] Reformat
     new cca4d92  Merge pull request #2948 from lizhimins/fix-offset

The 1609 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:
 .../impl/consumer/DefaultLitePullConsumerImpl.java | 18 ++++++++++++----
 .../impl/consumer/DefaultMQPushConsumerImpl.java   | 13 ++++++++---
 .../rocketmq/client/impl/consumer/PullRequest.java | 10 ++++-----
 .../client/impl/consumer/RebalanceImpl.java        | 20 ++++++++++++++++-
 .../impl/consumer/RebalanceLitePullImpl.java       | 18 ++++++++++++++--
 .../client/impl/consumer/RebalancePullImpl.java    |  7 ++++++
 .../client/impl/consumer/RebalancePushImpl.java    | 21 +++++++++++++++---
 .../client/consumer/DefaultMQPushConsumerTest.java | 25 ++++++++++++++++++++--
 8 files changed, 112 insertions(+), 20 deletions(-)