public void assertConnectorDoesNotExist(String connectorName, String detailMessage)
            throws InterruptedException {
        try {
            waitForCondition(
                () -> checkConnectorDoesNotExist(connectorName),
                CONNECTOR_SETUP_DURATION_MS,
                "The connector should not exist.");
        } catch (AssertionError e) {
            throw new AssertionError(detailMessage, e);
        }
    }
Assert that a connector does not exist. This can be used to verify that a connector has been successfully deleted.

@param connectorName the connector name
@param detailMessage the assertion message
@throws InterruptedException
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/ConnectAssertions.java