public class KafkaConsumerRecordImpl<K,V> extends Object implements KafkaConsumerRecord<K,V>
| Constructor and Description |
|---|
KafkaConsumerRecordImpl(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)
Constructor
|
| Modifier and Type | Method and Description |
|---|---|
long |
checksum()
Deprecated.
|
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() |
String |
toString() |
V |
value() |
public String topic()
topic in interface KafkaConsumerRecord<K,V>public int partition()
partition in interface KafkaConsumerRecord<K,V>public long offset()
offset in interface KafkaConsumerRecord<K,V>public long timestamp()
timestamp in interface KafkaConsumerRecord<K,V>public org.apache.kafka.common.record.TimestampType timestampType()
timestampType in interface KafkaConsumerRecord<K,V>@Deprecated public long checksum()
checksum in interface KafkaConsumerRecord<K,V>public K key()
key in interface KafkaConsumerRecord<K,V>public V value()
value in interface KafkaConsumerRecord<K,V>public org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record()
record in interface KafkaConsumerRecord<K,V>public List<KafkaHeader> headers()
headers in interface KafkaConsumerRecord<K,V>Copyright © 2020. All rights reserved.