From 71df9d1766c4ee72d043453087904b072c58d1fa Mon Sep 17 00:00:00 2001
From: ccwss <1782935682@qq.com>
Date: Tue, 16 Sep 2025 18:19:23 +0800
Subject: [PATCH] update dateVersion when load from local

---
 .../apache/rocketmq/broker/offset/LmqConsumerOffsetManager.java  | 1 +
 1 file changed, 1 insertion(+)

diff --git a/broker/src/main/java/org/apache/rocketmq/broker/offset/LmqConsumerOffsetManager.java b/broker/src/main/java/org/apache/rocketmq/broker/offset/LmqConsumerOffsetManager.java
index a565ad07c3a..faacc554067 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/offset/LmqConsumerOffsetManager.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/offset/LmqConsumerOffsetManager.java
@@ -96,6 +96,7 @@ public void decode(String jsonString) {
             LmqConsumerOffsetManager obj = RemotingSerializable.fromJson(jsonString, LmqConsumerOffsetManager.class);
             if (obj != null) {
                 super.setOffsetTable(obj.getOffsetTable());
+                super.setDataVersion(obj.getDataVersion());
                 this.lmqOffsetTable = obj.lmqOffsetTable;
             }
         }