private void waitForGet() {
        try {
            getCalledLatch.await();
        } catch (InterruptedException e) {
            throw new RuntimeException("Unexpected interruption: ", e);
        }
    }
Block, waiting for another thread to call one of the get() methods, and then immediately resolve the future with
the specified value.
@param t the exception to use to resolve the future
connect/runtime/src/test/java/org/apache/kafka/connect/util/TestFuture.java