@AfterEach
    public void close() {
        // stop the Connect cluster and its backing Kafka cluster.
        connect.stop();
        // unblock everything so that we don't leak threads after each test run
        Block.reset();
        Block.join();
    }
Tests situations during which certain connector operations, such as start, validation,
configuration and others, take longer than expected.
connect/runtime/src/test/java/org/apache/kafka/connect/integration/BlockingConnectorTest.java