diff --git a/src/main/java/org/apache/rocketmq/dashboard/service/impl/MessageServiceImpl.java b/src/main/java/org/apache/rocketmq/dashboard/service/impl/MessageServiceImpl.java
index 69a2b2ca..d44fdffd 100644
--- a/src/main/java/org/apache/rocketmq/dashboard/service/impl/MessageServiceImpl.java
+++ b/src/main/java/org/apache/rocketmq/dashboard/service/impl/MessageServiceImpl.java
@@ -370,6 +370,7 @@ private MessagePageTask queryFirstMessagePage(MessageQueryByPage query) {
 
                 while (size > 0) {
                     PullResult pullResult = consumer.pull(queueOffsetInfo.getMessageQueues(), "*", start, 32);
+                    start = pullResult.getNextBeginOffset();
                     if (pullResult.getPullStatus() == PullStatus.FOUND) {
                         List<MessageExt> poll = pullResult.getMsgFoundList();
                         if (poll.size() == 0) {
@@ -437,6 +438,7 @@ private Page<MessageView> queryMessageByTaskPage(MessageQueryByPage query, List<
 
                 while (size > 0) {
                     PullResult pullResult = consumer.pull(queueOffsetInfo.getMessageQueues(), "*", start, 32);
+                    start = pullResult.getNextBeginOffset();
                     if (pullResult.getPullStatus() == PullStatus.FOUND) {
                         List<MessageExt> poll = pullResult.getMsgFoundList();
                         if (poll.size() == 0) {