From ca97b160717d3b460c187816977e6dad6196b89d Mon Sep 17 00:00:00 2001
From: Liu Jicong <liujicong@qq.com>
Date: Wed, 16 Feb 2022 16:27:09 +0800
Subject: [PATCH] remove eager rebalance

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

diff --git a/source/dnode/mnode/impl/src/mndSubscribe.c b/source/dnode/mnode/impl/src/mndSubscribe.c
index 19a38a1212..c16a621b0d 100644
--- a/source/dnode/mnode/impl/src/mndSubscribe.c
+++ b/source/dnode/mnode/impl/src/mndSubscribe.c
@@ -1036,6 +1036,7 @@ static int32_t mndProcessSubscribeReq(SMnodeMsg *pMsg) {
       taosArrayPush(pSub->consumers, &mqSubConsumer);
 
       // if have un assigned vg, assign one to the consumer
+#if 0
       if (taosArrayGetSize(pSub->unassignedVg) > 0) {
         SMqConsumerEp *pConsumerEp = taosArrayPop(pSub->unassignedVg);
         pConsumerEp->oldConsumerId = pConsumerEp->consumerId;
@@ -1049,6 +1050,7 @@ static int32_t mndProcessSubscribeReq(SMnodeMsg *pMsg) {
         // do not set status active to trigger rebalance
         /*atomic_store_32(&pConsumer->status, MQ_CONSUMER_STATUS__ACTIVE);*/
       }
+#endif
 
       SSdbRaw *pRaw = mndSubActionEncode(pSub);
       sdbSetRawStatus(pRaw, SDB_STATUS_READY);
-- 
GitLab