From f27becb76a11d456c3ef95849513fc5b69e1e323 Mon Sep 17 00:00:00 2001
From: wangmm0220 <wangmm0220@gmail.com>
Date: Thu, 14 Mar 2024 00:08:56 +0800
Subject: [PATCH] opti:tmq logic

---
 source/dnode/mnode/impl/src/mndConsumer.c | 1 +
 1 file changed, 1 insertion(+)

diff --git a/source/dnode/mnode/impl/src/mndConsumer.c b/source/dnode/mnode/impl/src/mndConsumer.c
index 3fa2ca379a..52671f6b66 100644
--- a/source/dnode/mnode/impl/src/mndConsumer.c
+++ b/source/dnode/mnode/impl/src/mndConsumer.c
@@ -642,6 +642,7 @@ static SMqConsumerObj* buildSubConsumer(SMnode *pMnode, SCMSubscribeReq *subscri
       goto _over;
     }
   }
+  mndReleaseConsumer(pMnode, pExistedConsumer);
   return pConsumerNew;
 
 _over: