From 221c01c09fede1c70d4da0565aaede368c1e1b00 Mon Sep 17 00:00:00 2001 From: ccwss <1782935682@qq.com> Date: Fri, 29 Aug 2025 10:40:15 +0800 Subject: [PATCH] fix queryMessagesByTopic --- .../rocketmq/dashboard/service/impl/MessageServiceImpl.java | 2 ++ 1 file changed, 2 insertions(+) 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 poll = pullResult.getMsgFoundList(); if (poll.size() == 0) { @@ -437,6 +438,7 @@ private Page queryMessageByTaskPage(MessageQueryByPage query, List< while (size > 0) { PullResult pullResult = consumer.pull(queueOffsetInfo.getMessageQueues(), "*", start, 32); + start = pullResult.getNextBeginOffset(); if (pullResult.getPullStatus() == PullStatus.FOUND) { List poll = pullResult.getMsgFoundList(); if (poll.size() == 0) {