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