private void assign(Partition partition,
            Map<String, Map<String, List<Partition>>> clusterState,
            String consumerId) {
        Map<String, List<Partition>> partitions =
                clusterState.computeIfAbsent(consumerId, k -> new HashMap<>());
        List<Partition> ps = partitions.computeIfAbsent(
                partition.getTopic(), k -> new ArrayList<>());
        ps.add(partition);
    }
Load 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