private void verifyNormalConnector() throws InterruptedException {
        waitForConnectorStart(NORMAL_CONNECTOR_NAME);
        normalConnectorHandle.awaitRecords(RECORD_TRANSFER_TIMEOUT_MS);
        normalConnectorHandle.awaitCommits(RECORD_TRANSFER_TIMEOUT_MS);
    }
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