connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/Utils.java [61:74]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public static List<BrokerData> examineBrokerData(DefaultMQAdminExt defaultMQAdminExt, String topic,
        String cluster) throws RemotingException, MQClientException, InterruptedException {
        List<BrokerData> brokerList = new ArrayList<>();

        TopicRouteData topicRouteData = defaultMQAdminExt.examineTopicRouteInfo(topic);
        if (topicRouteData.getBrokerDatas() != null) {
            for (BrokerData broker : topicRouteData.getBrokerDatas()) {
                if (StringUtils.equals(broker.getCluster(), cluster)) {
                    brokerList.add(broker);
                }
            }
        }
        return brokerList;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/Utils.java [61:74]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public static List<BrokerData> examineBrokerData(DefaultMQAdminExt defaultMQAdminExt, String topic,
        String cluster) throws RemotingException, MQClientException, InterruptedException {
        List<BrokerData> brokerList = new ArrayList<>();

        TopicRouteData topicRouteData = defaultMQAdminExt.examineTopicRouteInfo(topic);
        if (topicRouteData.getBrokerDatas() != null) {
            for (BrokerData broker : topicRouteData.getBrokerDatas()) {
                if (StringUtils.equals(broker.getCluster(), cluster)) {
                    brokerList.add(broker);
                }
            }
        }
        return brokerList;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/Utils.java [83:96]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public static List<BrokerData> examineBrokerData(DefaultMQAdminExt defaultMQAdminExt, String topic,
        String cluster) throws RemotingException, MQClientException, InterruptedException {
        List<BrokerData> brokerList = new ArrayList<>();

        TopicRouteData topicRouteData = defaultMQAdminExt.examineTopicRouteInfo(topic);
        if (topicRouteData.getBrokerDatas() != null) {
            for (BrokerData broker : topicRouteData.getBrokerDatas()) {
                if (StringUtils.equals(broker.getCluster(), cluster)) {
                    brokerList.add(broker);
                }
            }
        }
        return brokerList;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -