@Override
    public void handleReloadBroker(MasterEntry masterEntry, List<Integer> needReloadList, ClusterEntry clusterEntry) {
        // reload without exceed max broker.
        if (needReloadList.isEmpty()) {
            return;
        }
        int begin = 0;
        int end = 0;
        do {
            end = Math.min(clusterEntry.getReloadBrokerSize() + begin, needReloadList.size());
            List<Integer> brokerIdList = needReloadList.subList(begin, end);
            String brokerStr = StringUtils.join(brokerIdList, ",");
            String url = TubeConst.SCHEMA + masterEntry.getIp() + ":" + masterEntry.getWebPort()
                    + TubeConst.RELOAD_BROKER + TubeConst.BROKER_ID + brokerStr + TubeConst.CONF_MOD_AUTH_TOKEN
                    + masterEntry.getToken() + TubeConst.MODIFY_USER + "tubeadmin";
            HttpGet httpget = new HttpGet(url);
            try (CloseableHttpResponse response = httpclient.execute(httpget)) {
                TubeHttpResponse result =
                        gson.fromJson(new InputStreamReader(response.getEntity()
                                .getContent(), StandardCharsets.UTF_8), TubeHttpResponse.class);
                if (result.getErrCode() != TubeConst.SUCCESS_CODE) {
                    log.info("reload tube broker : {} to master {}, fail with msg: {}",
                            brokerStr, masterEntry.getIp(), result.getErrMsg());
                }
            } catch (Exception ex) {
                log.error("exception caught while requesting brokers {} status, master is {}",
                        brokerStr, masterEntry.getIp(), ex);
            }
            begin = end;
        } while (end < needReloadList.size());
    }
reload broker list, cannot exceed maxConfigurableBrokerSize each time.

@param masterEntry
@param needReloadList
inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/service/NodeServiceImpl.java