public void assertConnectorAndAtLeastNumTasksAreRunning(String connectorName, int numTasks, String detailMessage)
            throws InterruptedException {
        waitForConnectorState(
                connectorName,
                AbstractStatus.State.RUNNING,
                atLeast(numTasks),
                null,
                AbstractStatus.State.RUNNING,
                "The connector or at least " + numTasks + " of tasks are not running.",
                detailMessage,
                CONNECTOR_SETUP_DURATION_MS
        );
    }
Assert that a connector is running with at least the given number of tasks all in running state

@param connectorName the connector name
@param numTasks the number of tasks
@param detailMessage
@throws InterruptedException
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/ConnectAssertions.java