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 72b29e2030..a37c3a0149 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; }