public ConsumerRecords<byte[], byte[]> consume(int n, long maxDuration, String... topics) {
        return consume(n, maxDuration, Collections.emptyMap(), topics);
    }
Consume at least n records in a given duration or throw an exception.

@param n the number of expected records in this topic.
@param maxDuration the max duration to wait for these records (in milliseconds).
@param topics the topics to subscribe and consume records from.
@return a {@link ConsumerRecords} collection containing at least n records.
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedKafkaCluster.java