class ConsumerRecords implements Iterable<ConsumerRecord<K, V>> {

    @Override
    public Iterator<ConsumerRecord<K, V>> iterator() {
        return new ConcatenatedIterable<>(records.values()).iterator();
    }

    public  ConsumerRecords(Map<TopicPartition, List<ConsumerRecord<K, V>>> records);

}