public static void awaitLatch(CountDownLatch latch, String message) {
        awaitLatch(latch, DEFAULT_LATCH_AWAIT_TIME_MS, message);
    }
{@link CountDownLatch#await(long, TimeUnit) Await} the given latch, failing if the
{@link #DEFAULT_LATCH_AWAIT_TIME_MS default timeout} elapses or the wait is interrupted.
@param latch the latch to await; may not be null
@param message the failure message to use if the timeout elapses or the wait is interrupted; may be null
connect/runtime/src/test/java/org/apache/kafka/connect/test/util/ConcurrencyUtils.java