public static void deleteTopic()

in java/e2e-v4/src/main/java/org/apache/rocketmq/utils/MQAdmin.java [140:160]

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

    public static void deleteTopic(String nameSrvAddr, String cluster, String topic) {
        try {
            Set<String> set = new HashSet<>();
            set.add(nameSrvAddr);
            mqAdminExt.deleteTopicInNameServer(set, topic);

            boolean isTopicExist = checkTopicExist(mqAdminExt, topic);
            long startTime = System.currentTimeMillis();
            while (!isTopicExist) {
                isTopicExist = checkTopicExist(mqAdminExt, topic);
                if (System.currentTimeMillis() - startTime < 5 * 1000) {
                    TestUtils.waitForMoment(100);
                } else {
                    log.error(String.format("timeout,but delete topic[%s] failed!", topic));
                    break;
                }
            }

        } catch (Exception e) {
        }
    }