From 5964e7819c548faf9382b12e23de8142d32ac6fd Mon Sep 17 00:00:00 2001
From: plum-lihui <huili@taosdata.com>
Date: Thu, 6 Jul 2023 19:38:37 +0800
Subject: [PATCH] test: add check

---
 tests/system-test/7-tmq/tmqDropConsumer.py | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git a/tests/system-test/7-tmq/tmqDropConsumer.py b/tests/system-test/7-tmq/tmqDropConsumer.py
index 336285a39e..06ce4c0fd7 100644
--- a/tests/system-test/7-tmq/tmqDropConsumer.py
+++ b/tests/system-test/7-tmq/tmqDropConsumer.py
@@ -256,6 +256,7 @@ class TDTestCase:
         tdLog.info("all consumers status into 'lost'")
         
         # drop consumer groups
+        tdLog.info("drop all consumers")
         for i in range(len(groupIdList)): 
             for j in range(len(topicNameList)): 
                 sqlCmd = f"drop consumer group `%s` on %s"%(groupIdList[i], topicNameList[j])
@@ -265,7 +266,17 @@ class TDTestCase:
         tmqCom.g_end_insert_flag = 1
         tdLog.debug("notify sub-thread to stop insert data")
         pThread.join()
+        
+        tdSql.query('show consumers;')
+        consumerNUm = tdSql.queryRows
 
+        tdSql.query('show subscriptions;')
+        subscribeNum = tdSql.queryRows
+        
+        if (0 != consumerNUm or 0 != subscribeNum):
+            tdLog.exit("drop consumer fail! consumerNUm %d, subscribeNum: %d"%(consumerNUm, subscribeNum))
+
+        tdLog.info("drop consuer success, there is no consumers and subscribes")
         tdLog.printNoPrefix("======== test case 1 end ...... ")
 
     def run(self):