@AfterAll
    public static void close() {
        if (connect != null) {
            Utils.closeQuietly(connect::stop, "Embedded Connect cluster");
        }
    }
Integration test for preflight connector config validation
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorValidationIntegrationTest.java