public void waitForRemainingTopics(final long timeoutMs, final String... topics) throws InterruptedException {
        TestUtils.waitForCondition(new TopicsRemainingCondition(topics), timeoutMs, "Topics are not expected after " + timeoutMs + " milli seconds.");
    }
Deletes all topics and blocks until all topics got deleted.

@param timeoutMs the max time to wait for the topics to be deleted (does not block if {@code <= 0})
streams/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedKafkaCluster.java