public static List getBackendsV2()

in src/main/java/org/apache/doris/kafka/connector/service/RestService.java [76:99]

• 23 lines of code
• 4 McCabe index (conditional complexity)

    public static List<BackendV2.BackendRowV2> getBackendsV2(DorisOptions options, Logger logger) {
        List<String> feNodeList = options.getHttpUrls();
        if (options.isAutoRedirect()) {
            return convert(feNodeList);
        }

        for (String feNode : feNodeList) {
            try {
                String beUrl = "http://" + feNode + BACKENDS_V2;
                HttpGet httpGet = new HttpGet(beUrl);
                String response = send(options, httpGet, logger);
                logger.info("Backend Info:{}", response);
                return parseBackendV2(response, logger);
            } catch (ConnectedFailedException e) {
                logger.info(
                        "Doris FE node {} is unavailable: {}, Request the next Doris FE node",
                        feNode,
                        e.getMessage());
            }
        }
        String errMsg = "No Doris FE is available, please check configuration";
        logger.error(errMsg);
        throw new DorisException(errMsg);
    }