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;
             }
         }