diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c
index c4800e50510b69d4fd669c15465300fc0c9f8af9..f48b57b74b220f126b1cc8890d5b8640cce6467b 100644
--- a/source/dnode/vnode/src/tq/tq.c
+++ b/source/dnode/vnode/src/tq/tq.c
@@ -593,7 +593,9 @@ static int32_t extractDataForMq(STQ* pTq, STqHandle* pHandle, const SMqPollReq*
             ",version:%" PRId64,
             consumerId, pHandle->subKey, vgId, taosxRsp.blockNum, taosxRsp.rspOffset.type, taosxRsp.rspOffset.uid,
             taosxRsp.rspOffset.version);
-  } else {
+  }
+
+  if (offset.type == TMQ_OFFSET__LOG) {
 
 //  if (offset.type == TMQ_OFFSET__LOG) {
     int64_t fetchVer = offset.version + 1;