Skip to content

Commit 15796e7

Browse files
woaishixiaoxiaoshixiaoxiao
andauthored
[ISSUE #9912] Fix consumer offset timestamp displayed incorrect in tiered store (#9913)
Co-authored-by: shixiaoxiao <[email protected]>
1 parent 6f5b551 commit 15796e7

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

tieredstore/src/main/java/org/apache/rocketmq/tieredstore/TieredMessageStore.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -356,6 +356,11 @@ public CompletableFuture<Long> getEarliestMessageTimeAsync(String topic, int que
356356
});
357357
}
358358

359+
@Override
360+
public long getMessageStoreTimeStamp(String topic, int queueId, long consumeQueueOffset) {
361+
return getMessageStoreTimeStampAsync(topic, queueId, consumeQueueOffset).join();
362+
}
363+
359364
@Override
360365
public CompletableFuture<Long> getMessageStoreTimeStampAsync(String topic, int queueId,
361366
long consumeQueueOffset) {

0 commit comments

Comments
 (0)