public static void awaitLatch(CountDownLatch latch, long timeoutMs, String message) {
        try {
            assertTrue(latch.await(timeoutMs, TimeUnit.MILLISECONDS), message);
        } catch (InterruptedException e) {
            throw new AssertionError(message, e);
        }
    }
{@link CountDownLatch#await(long, TimeUnit) Await} the given latch, failing if the timeout elapses or the wait is interrupted.
@param latch the latch to await; may not be null
@param timeoutMs the maximum amount of time to wait for the latch, in milliseconds
@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