From 9966ff3efd72b7662037611ba2f898f3c26d09e5 Mon Sep 17 00:00:00 2001 From: xx Date: Wed, 5 Jun 2024 10:50:32 +0800 Subject: [PATCH] fix: Duplicate message in the topic tab message list in the message menu. --- .../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)); }