public class KafkaConsumerRecordsImpl<K,V> extends Object implements KafkaConsumerRecords<K,V>
| Constructor and Description |
|---|
KafkaConsumerRecordsImpl(org.apache.kafka.clients.consumer.ConsumerRecords<K,V> records) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
isEmpty() |
KafkaConsumerRecord<K,V> |
recordAt(int index)
Get the record at the given index
|
org.apache.kafka.clients.consumer.ConsumerRecords<K,V> |
records() |
int |
size() |
public int size()
size in interface KafkaConsumerRecords<K,V>public boolean isEmpty()
isEmpty in interface KafkaConsumerRecords<K,V>public KafkaConsumerRecord<K,V> recordAt(int index)
KafkaConsumerRecordsrecordAt in interface KafkaConsumerRecords<K,V>index - the index of the record to getCopyright © 2020. All rights reserved.