public void deleteTopic(final String topic) throws InterruptedException {
        deleteTopicsAndWait(-1L, topic);
    }
Deletes a topic returns immediately.

@param topic the name of the topic
streams/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedKafkaCluster.java