io.vertx.kafka.client.consumer

Interface KafkaConsumerRecord<K,V>

public interface KafkaConsumerRecord<K,V>

Vert.x Kafka consumer record

Method Summary

Modifier and Type	Method and Description
List<KafkaHeader>	headers()
K	key()
long	offset()
int	partition()
org.apache.kafka.clients.consumer.ConsumerRecord<K,V>	record()
long	timestamp()
org.apache.kafka.common.record.TimestampType	timestampType()
String	topic()
V	value()

Method Detail

topic

String topic()

Returns:

the topic this record is received from

partition

int partition()

Returns:

the partition from which this record is received

offset

long offset()

Returns:

the position of this record in the corresponding Kafka partition.

timestamp

long timestamp()

Returns:

the timestamp of this record

timestampType

org.apache.kafka.common.record.TimestampType timestampType()

Returns:

the timestamp type of this record

key

K key()

Returns:

the key (or null if no key is specified)

value

V value()

Returns:

the value

headers

List<KafkaHeader> headers()

Returns:

the list of consumer record headers

record

org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record()

Returns:

the native Kafka consumer record with backed information