private static Predicate<Integer> exactly(int expected) {
        return actual -> actual == expected;
    }
Check whether a connector's set of active topics matches the given collection of topic names.

@param connectorName the connector name
@param topics a collection of topics to compare against
@return true if the connector's active topics matches the given collection; false otherwise
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/ConnectAssertions.java