@Override
    public Map<String, Map<String, Map<String, Partition>>> resetBalanceCluster(
            Map<String, Map<String, Map<String, Partition>>> clusterState,
            ConsumerInfoHolder consumerHolder, BrokerRunManager brokerRunManager,
            List<String> groupSet, MetaDataService defMetaDataService, StringBuilder strBuffer) {
        return inReBalanceCluster(true, consumerHolder,
                brokerRunManager, groupSet, defMetaDataService, strBuffer);
    }
Reset balance

@param clusterState
@param consumerHolder
@param brokerRunManager
@param groupSet
@param defMetaDataService
@param strBuffer
@return
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/balance/DefaultLoadBalancer.java