org.apache.kafka.clients.consumer

Class ConsumerRecords<K,V>

java.lang.Object

org.apache.kafka.clients.consumer.ConsumerRecords<K,V>

All Implemented Interfaces:

java.lang.Iterable<ConsumerRecord<K,V>>

public class ConsumerRecords<K,V>
extends java.lang.Object
implements java.lang.Iterable<ConsumerRecord<K,V>>

A container that holds the list ConsumerRecord per partition for a particular topic. There is one ConsumerRecord list for every topic partition returned by a Consumer.poll(java.time.Duration) operation.

Field Summary

Fields

Modifier and Type	Field and Description
static ConsumerRecords<java.lang.Object,java.lang.Object>	EMPTY

Constructor Summary

Constructors

Constructor and Description
ConsumerRecords(java.util.Map<TopicPartition,java.util.List<ConsumerRecord<K,V>>> records)

Method Summary

Modifier and Type	Method and Description
int	count() The number of records for all topics
static <K,V> ConsumerRecords<K,V>	empty()
boolean	isEmpty()
java.util.Iterator<ConsumerRecord<K,V>>	iterator()
java.util.Set<TopicPartition>	partitions() Get the partitions which have records contained in this record set.
java.lang.Iterable<ConsumerRecord<K,V>>	records(java.lang.String topic) Get just the records for the given topic
java.util.List<ConsumerRecord<K,V>>	records(TopicPartition partition) Get just the records for the given partition

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

EMPTY

public static final ConsumerRecords<java.lang.Object,java.lang.Object> EMPTY

Constructor Detail

ConsumerRecords

public ConsumerRecords(java.util.Map<TopicPartition,java.util.List<ConsumerRecord<K,V>>> records)

Method Detail

records

public java.util.List<ConsumerRecord<K,V>> records(TopicPartition partition)

Get just the records for the given partition

Parameters:

partition - The partition to get records for

records

public java.lang.Iterable<ConsumerRecord<K,V>> records(java.lang.String topic)

Get just the records for the given topic

partitions

public java.util.Set<TopicPartition> partitions()

Get the partitions which have records contained in this record set.

Returns:

the set of partitions with data in this record set (may be empty if no data was returned)

iterator

public java.util.Iterator<ConsumerRecord<K,V>> iterator()

Specified by:

iterator in interface java.lang.Iterable<ConsumerRecord<K,V>>

count

public int count()

The number of records for all topics

isEmpty

public boolean isEmpty()

empty

public static <K,V> ConsumerRecords<K,V> empty()