Package io.vertx.kafka.client.consumer
Interface KafkaConsumerRecord<K,V>
-
public interface KafkaConsumerRecord<K,V>Vert.x Kafka consumer record
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description List<KafkaHeader>headers()Kkey()longoffset()intpartition()org.apache.kafka.clients.consumer.ConsumerRecord<K,V>record()longtimestamp()org.apache.kafka.common.record.TimestampTypetimestampType()Stringtopic()Vvalue()
-
-
-
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
-
-