From 129d04a4495f1a01d390b2c8ee1e7192484a0ef1 Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao>
Date: Wed, 29 May 2024 16:29:04 +0800
Subject: [PATCH] adj tmq param

---
 source/dnode/vnode/src/tq/tqUtil.c | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/source/dnode/vnode/src/tq/tqUtil.c b/source/dnode/vnode/src/tq/tqUtil.c
index 496201e79e..33e3414a7d 100644
--- a/source/dnode/vnode/src/tq/tqUtil.c
+++ b/source/dnode/vnode/src/tq/tqUtil.c
@@ -283,7 +283,7 @@ static int32_t extractDataAndRspForDbStbSubscribe(STQ* pTq, STqHandle* pHandle,
 
         tqDebug("fetch meta msg, ver:%" PRId64 ", vgId:%d, type:%s, enable batch meta:%d", pHead->version, vgId,
                 TMSG_INFO(pHead->msgType), pRequest->enableBatchMeta);
-        if (!pRequest->enableBatchMeta) {
+        if (!pRequest->enableBatchMeta && !pRequest->useSnapshot) {
           SMqMetaRsp metaRsp = {0};
           tqOffsetResetToLog(&metaRsp.rspOffset, fetchVer + 1);
           metaRsp.resMsgType = pHead->msgType;