public void assertConnectorActiveTopics(String connectorName, Collection<String> topics, String detailMessage) throws InterruptedException {
        try {
            waitForCondition(
                () -> checkConnectorActiveTopics(connectorName, topics).orElse(false),
                CONNECT_INTERNAL_TOPIC_UPDATES_DURATION_MS,
                "Connector active topics don't match the expected collection");
        } catch (AssertionError e) {
            throw new AssertionError(detailMessage, e);
        }
    }
Assert that 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
@param detailMessage the assertion message
@throws InterruptedException
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/ConnectAssertions.java