public static Map<String, String> lookupPartitionedTopic(RestTemplate restTemplate, PulsarClusterInfo clusterInfo,
            String topicPath) throws Exception {
        PulsarTopicMetadata metadata = getPartitionedTopicMetadata(restTemplate, clusterInfo, topicPath);
        Map<String, String> map = new LinkedHashMap<>();
        for (int i = 0; i < metadata.getPartitions(); i++) {
            String partitionTopicName = topicPath + "-partition-" + i;
            PulsarLookupTopicInfo topicInfo = HttpUtils.request(restTemplate,
                    clusterInfo.getAdminUrls(LOOKUP_TOPIC_PATH + "/persistent/" + partitionTopicName), HttpMethod.GET,
                    null,
                    getHttpHeaders(clusterInfo.getToken()), PulsarLookupTopicInfo.class);
            map.put(partitionTopicName, topicInfo.getBrokerUrl());
        }
        return map;
    }
lookup persistent partitioned topic info.

@param restTemplate spring framework RestTemplate
@param clusterInfo pulsar cluster info
@param topicPath pulsar topic path
@return map of partitioned topic info
@throws Exception any exception if occurred
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/pulsar/PulsarUtils.java