public static void waitForCondition(final TestCondition testCondition, final String conditionDetails) throws InterruptedException {
        waitForCondition(testCondition, DEFAULT_MAX_WAIT_MS, () -> conditionDetails);
    }
uses default value of 15 seconds for timeout
clients/src/test/java/org/apache/kafka/test/TestUtils.java