From 3fbaa3ab920fc6f05f2a5baf5982331e0f8d5dd2 Mon Sep 17 00:00:00 2001 From: xx <129470203+boomboomxx@users.noreply.github.com> Date: Mon, 4 Nov 2024 11:35:17 +0800 Subject: [PATCH] fix: Duplicate message in the topic tab message list in the message menu. (#202) Co-authored-by: xx --- .../rocketmq/dashboard/service/impl/MessageServiceImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 d51197f..16d0d4e 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 @@ -276,7 +276,7 @@ public class MessageServiceImpl implements MessageService { int idx = 0; for (MessageQueue messageQueue : messageQueues) { Long minOffset = consumer.searchOffset(messageQueue, query.getBegin()); - Long maxOffset = consumer.searchOffset(messageQueue, query.getEnd()) + 1; + Long maxOffset = consumer.searchOffset(messageQueue, query.getEnd()); queueOffsetInfos.add(new QueueOffsetInfo(idx++, minOffset, maxOffset, minOffset, minOffset, messageQueue)); }