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);