diff --git a/source/dnode/mnode/impl/src/mndSubscribe.c b/source/dnode/mnode/impl/src/mndSubscribe.c index 19a38a1212072909a3d2674ac7fd90130eb890bf..c16a621b0dd7810d697243e2c3473d9d110a7b13 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);