private void assertConnectorAllocations(int... connectorCounts) {
        assertAllocations("connectors", ConnectorsAndTasks::connectors, connectorCounts);
    }
Assert that the connector counts for each worker in the cluster match the expected counts.
For example, calling {@code assertConnectorAllocations(0, 0, 2, 3)} ensures that there are two
workers in the cluster that are assigned no connectors, one worker that is assigned two connectors,
and one worker that is assigned three connectors.
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignorTest.java