From c866c9ad024c4c0baa5d6cf37c922138ec65f3e5 Mon Sep 17 00:00:00 2001
From: wangmm0220 <wangmm0220@gmail.com>
Date: Thu, 14 Mar 2024 14:27:13 +0800
Subject: [PATCH] fix:case error

---
 source/dnode/mnode/impl/src/mndSubscribe.c | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/source/dnode/mnode/impl/src/mndSubscribe.c b/source/dnode/mnode/impl/src/mndSubscribe.c
index e860c01c36..a6d7a24323 100644
--- a/source/dnode/mnode/impl/src/mndSubscribe.c
+++ b/source/dnode/mnode/impl/src/mndSubscribe.c
@@ -935,8 +935,7 @@ static int32_t mndDropConsumerByGroup(SMnode *pMnode, STrans *pTrans, char *cgro
       break;
     }
 
-    if (strcmp(cgroup, pConsumer->cgroup) == 0 && taosArrayGetSize(pConsumer->assignedTopics) == 1 &&
-        strcmp(topic, taosArrayGetP(pConsumer->assignedTopics, 0)) == 0) {
+    if (strcmp(cgroup, pConsumer->cgroup) == 0 && taosArrayGetSize(pConsumer->currentTopics) == 0) {
       int32_t code = mndSetConsumerDropLogs(pTrans, pConsumer);
       if (code != 0) {
         sdbRelease(pMnode->pSdb, pConsumer);