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: