refactor: do some internal refactor.

source/client/test/clientTests.cpp

@@ -925,7 +925,8 @@ TEST(clientCase, subscription_test) {
 
   // 创建订阅 topics 列表
   tmq_list_t* topicList = tmq_list_new();
-//  tmq_list_append(topicList, "topic_t1");
+  tmq_list_append(topicList, "topic_t1");
+  tmq_list_append(topicList, "topic_s2");
 
   // 启动订阅
   tmq_subscribe(tmq, topicList);
@@ -954,7 +955,7 @@ TEST(clientCase, subscription_test) {
       printf("db: %s\n", dbName);
       printf("vgroup id: %d\n", vgroupId);
 
-      if (count ++ > 20) {
+      if (count ++ > 40) {
         tmq_unsubscribe(tmq);
         break;
       }

source/dnode/mnode/impl/src/mndSubscribe.c

@@ -611,8 +611,6 @@ static int32_t mndProcessRebalanceReq(SRpcMsg *pMsg) {
       break;
     }
 
-    taosSsleep(20);
-
     SMqRebInputObj rebInput = {0};
     SMqRebOutputObj rebOutput = {0};
     rebOutput.newConsumers = taosArrayInit(0, sizeof(int64_t));