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 72b29e203042d8973cccf5853cb4be8b1ba8bcf8..a37c3a0149047a7313e9cc2f3a92e3b4bc0a07c4 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; }