(rocketmq) branch develop updated: [ISSUE #9912] Fix consumer offset timestamp displayed incorrect in tiered store (#9913)

[lizhimin]

This is an automated email from the ASF dual-hosted git repository.

lizhimin pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 15796e73d3 [ISSUE #9912] Fix consumer offset timestamp displayed 
incorrect in tiered store (#9913)
15796e73d3 is described below

commit 15796e73d39db1c5387fa80dde22c959f2bea99d
Author: SHI <34100836+woaishixiaox...@users.noreply.github.com>
AuthorDate: Fri Dec 12 16:10:09 2025 +0800

    [ISSUE #9912] Fix consumer offset timestamp displayed incorrect in tiered 
store (#9913)
    
    Co-authored-by: shixiaoxiao <shixiaox...@bytedance.com>
---
 .../java/org/apache/rocketmq/tieredstore/TieredMessageStore.java     | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/TieredMessageStore.java
 
b/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/TieredMessageStore.java
index 68ae8acc9e..3e84f20122 100644
--- 
a/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/TieredMessageStore.java
+++ 
b/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/TieredMessageStore.java
@@ -356,6 +356,11 @@ public class TieredMessageStore extends 
AbstractPluginMessageStore {
             });
     }
 
+    @Override
+    public long getMessageStoreTimeStamp(String topic, int queueId, long 
consumeQueueOffset) {
+        return getMessageStoreTimeStampAsync(topic, queueId, 
consumeQueueOffset).join();
+    }
+
     @Override
     public CompletableFuture<Long> getMessageStoreTimeStampAsync(String topic, 
int queueId,
         long consumeQueueOffset) {