diff --git a/source/client/src/clientTmq.c b/source/client/src/clientTmq.c
index d9f021211c..53a534b83a 100644
--- a/source/client/src/clientTmq.c
+++ b/source/client/src/clientTmq.c
@@ -2794,7 +2794,7 @@ int32_t tmq_offset_seek(tmq_t* tmq, const char* pTopicName, int32_t vgId, int64_
 
   // update the offset, and then commit to vnode
   if (pOffsetInfo->currentOffset.type == TMQ_OFFSET__LOG) {
-    pOffsetInfo->currentOffset.version = offset;
+    pOffsetInfo->currentOffset.version = offset - 1;
     pOffsetInfo->committedOffset.version = INT64_MIN;
     pVg->seekUpdated = true;
   }