io.vertx.kafka.client.consumer

Interface KafkaConsumerRecords<K,V>

public interface KafkaConsumerRecords<K,V>

Vert.x Kafka consumer records

Method Summary

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()

Method Detail

size

int size()

Returns:

the total number of records in this batch

isEmpty

boolean isEmpty()

Returns:

whether this batch contains any records

recordAt

KafkaConsumerRecord<K,V> recordAt(int index)

Get the record at the given index

Parameters:

index - the index of the record to get

Throws:

IndexOutOfBoundsException - if index <0 or index>=size()

records

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

Returns:

the native Kafka consumer records with backed information