@Test
    public void testLookupPartitionedTopic() throws Exception {
        final String topicPath = DEFAULT_TENANT + InlongConstants.SLASH + DEFAULT_NAMESPACE + InlongConstants.SLASH
                + "testLookupPartitionedTopic";
        PulsarUtils.createNonPartitionedTopic(client, pulsarCluster, topicPath);
        Thread.sleep(500);
        Map<String, String> actual = PulsarUtils.lookupPartitionedTopic(client, pulsarCluster, topicPath);
        assertNotNull(actual);
    }
Test cases for {@link PulsarUtils#lookupPartitionedTopic(RestTemplate, PulsarClusterInfo, String)}.

@throws Exception
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/queue/PulsarUtilsTest.java