fix:memory leak

This commit is contained in:
wangmm0220 2023-08-23 19:41:02 +08:00
parent 775f0668c5
commit be74370e98
1 changed files with 1 additions and 0 deletions

View File

@ -725,6 +725,7 @@ static int32_t mndProcessDropTopicReq(SRpcMsg *pReq) {
if (found){
if (pConsumer->status == MQ_CONSUMER_STATUS_LOST) {
mndDropConsumerFromSdb(pMnode, pConsumer->consumerId);
mndReleaseConsumer(pMnode, pConsumer);
continue;
}