feat:ignore delete info

source/dnode/vnode/src/tq/tqRead.c

@@ -218,7 +218,7 @@ int32_t tqFetchLog(STQ* pTq, STqHandle* pHandle, int64_t* fetchOffset, SWalCkHea
     } else {
       if (pHandle->fetchMeta != WITH_DATA) {
         SWalCont* pHead = &((*ppCkHead)->head);
-        if (IS_META_MSG(pHead->msgType)) {
+        if (IS_META_MSG(pHead->msgType) && !(pHead->msgType == TDMT_VND_DELETE && pHandle->fetchMeta == ONLY_META)) {
           code = walFetchBody(pHandle->pWalReader, ppCkHead);
           if (code < 0) {
             *fetchOffset = offset;

tests/system-test/7-tmq/tmq_taosx.py

@@ -220,6 +220,17 @@ class TDTestCase:
 
         return
 
+    def checkWal1VgroupOnlyMeta(self):
+        buildPath = tdCom.getBuildPath()
+        cfgPath = tdCom.getClientCfgPath()
+        cmdStr = '%s/build/bin/tmq_taosx_ci -c %s -sv 1 -dv 1 -d -onlymeta'%(buildPath, cfgPath)
+        tdLog.info(cmdStr)
+        os.system(cmdStr)
+
+        self.checkJson(cfgPath, "tmq_taosx_tmp")
+
+        return
+
     def checkWal1VgroupTable(self):
         buildPath = tdCom.getBuildPath()
         cfgPath = tdCom.getClientCfgPath()
@@ -301,6 +312,8 @@ class TDTestCase:
 
     def run(self):
         tdSql.prepare()
+        self.checkWal1VgroupOnlyMeta()
+
         self.checkWal1Vgroup()
         self.checkSnapshot1Vgroup()