@Test
    public void testCreateNonPartitionedTopic() throws Exception {
        final String topicPath = DEFAULT_TENANT + InlongConstants.SLASH + DEFAULT_NAMESPACE + InlongConstants.SLASH
                + "testCreateNonPartitionedTopic";
        final String topicInfo = PERSISTENT_TOPIC_HEAD + topicPath;

        Thread.sleep(500);
        PulsarUtils.createNonPartitionedTopic(client, pulsarCluster, topicPath);
        Thread.sleep(500);
        List<String> topics = PulsarUtils.getTopics(client, pulsarCluster, DEFAULT_TENANT,
                DEFAULT_NAMESPACE);
        assertTrue(topics.contains(topicInfo));
    }
Test cases for {@link PulsarUtils#createNonPartitionedTopic(RestTemplate, PulsarClusterInfo, String)}.

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