private void assertConnectorRunning() throws InterruptedException {
        connect.assertions().assertConnectorAndAtLeastNumTasksAreRunning(CONNECTOR_NAME, NUM_TASKS,
                "Connector tasks did not start in time.");
    }
Test the {@link Filter} transformer with a
{@link TopicNameMatches} predicate on a sink connector.
connect/runtime/src/test/java/org/apache/kafka/connect/integration/TransformationIntegrationTest.java