From a3bab0eb623339db49e61309b52d8078efcae04d Mon Sep 17 00:00:00 2001
From: rongtongjin <794220751@qq.com>
Date: Wed, 18 Sep 2019 16:48:49 +0800
Subject: [PATCH] Fix(client):fix the issue that lite pull consumer lost
 messages in some scenario

	In jepsen test, consumer lost messages when using the lite pull consumer. This is due to the incorrect setting of consume offset. Delete the wrong code to make it correct.
---
 .../client/impl/consumer/DefaultLitePullConsumerImpl.java        | 1 -
 1 file changed, 1 deletion(-)

diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java
index 72b29e20..a37c3a01 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java
@@ -676,7 +676,6 @@ public class DefaultLitePullConsumerImpl implements MQConsumerInner {
                     offset = 0;
                 }
             }
-            assignedMessageQueue.updateConsumeOffset(messageQueue, offset);
         }
         return offset;
     }
-- 
GitLab