public static <V> List<V> waitUntilMinValuesRecordsReceived(final Properties consumerConfig,
                                                                final String topic,
                                                                final int expectedNumRecords) throws Exception {
        return waitUntilMinValuesRecordsReceived(consumerConfig, topic, expectedNumRecords, DEFAULT_TIMEOUT);
    }
Wait until enough data (value records) has been consumed.

@param consumerConfig     Kafka Consumer configuration
@param topic              Topic to consume from
@param expectedNumRecords Minimum number of expected records
@return All the records consumed, or null if no records are consumed
@throws AssertionError    if the given wait time elapses
streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java