public interface KafkaConsumerRecord<K,V>
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() |
String topic()
int partition()
long offset()
long timestamp()
org.apache.kafka.common.record.TimestampType timestampType()
K key()
V value()
List<KafkaHeader> headers()
Copyright © 2023 Eclipse. All rights reserved.