From 1262c605f371ae222cc0dbb8d2a0e2f6c31c6324 Mon Sep 17 00:00:00 2001
From: Humkum <1109939087@qq.com>
Date: Thu, 19 Mar 2026 19:44:15 +0800
Subject: [PATCH] fix: consume offset may be abnormally reset to min in
 litePullConsumer

---
 .../client/impl/consumer/DefaultLitePullConsumerImpl.java      | 3 +++
 1 file changed, 3 insertions(+)

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 6ce8b2d1cd4..634d80761a2 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
@@ -954,6 +954,9 @@ public void run() {
                 long offset = 0L;
                 try {
                     offset = nextPullOffset(messageQueue);
+                    if (offset < 0) {
+                        throw new MQClientException(ResponseCode.SYSTEM_ERROR, "Unexpected offset " + offset);
+                    }
                 } catch (Exception e) {
                     log.error("Failed to get next pull offset", e);
                     scheduledThreadPoolExecutor.schedule(this, PULL_TIME_DELAY_MILLS_ON_EXCEPTION, TimeUnit.MILLISECONDS);