public static synchronized void reset() {
            resetAwaitBlockLatch();
            BLOCK_LATCHES.forEach(CountDownLatch::countDown);
            BLOCK_LATCHES.clear();
        }
{@link CountDownLatch#countDown() Release} any latches allocated over the course of a test
to either await a connector/task reaching a blocking point, or cause a connector/task to block.
connect/runtime/src/test/java/org/apache/kafka/connect/integration/BlockingConnectorTest.java