public void deleteTopicAndWait(final String topic) throws InterruptedException {
        deleteTopicsAndWait(TOPIC_DELETION_TIMEOUT, topic);
    }
Deletes a topic and blocks for max 30 sec until the topic got deleted.

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