| Modifier and Type | Field and Description |
|---|---|
static <any> |
__TYPE_ARG |
<any> |
__typeArg_0 |
<any> |
__typeArg_1 |
| Constructor and Description |
|---|
KafkaConsumerRecord(KafkaConsumerRecord delegate) |
KafkaConsumerRecord(KafkaConsumerRecord delegate,
<any> typeArg_0,
<any> typeArg_1) |
| Modifier and Type | Method and Description |
|---|---|
long |
checksum()
Deprecated.
|
boolean |
equals(Object o) |
KafkaConsumerRecord |
getDelegate() |
int |
hashCode() |
List<KafkaHeader> |
headers() |
K |
key() |
static <K,V> KafkaConsumerRecord<K,V> |
newInstance(KafkaConsumerRecord arg) |
static <K,V> KafkaConsumerRecord<K,V> |
newInstance(KafkaConsumerRecord arg,
<any> __typeArg_K,
<any> __typeArg_V) |
long |
offset() |
int |
partition() |
long |
timestamp() |
org.apache.kafka.common.record.TimestampType |
timestampType() |
String |
topic() |
String |
toString() |
V |
value() |
public static final <any> __TYPE_ARG
public final <any> __typeArg_0
public final <any> __typeArg_1
public KafkaConsumerRecord(KafkaConsumerRecord delegate)
public KafkaConsumerRecord(KafkaConsumerRecord delegate, <any> typeArg_0, <any> typeArg_1)
public KafkaConsumerRecord getDelegate()
public String topic()
public int partition()
public long offset()
public long timestamp()
public org.apache.kafka.common.record.TimestampType timestampType()
@Deprecated public long checksum()
public K key()
public V value()
public List<KafkaHeader> headers()
public static <K,V> KafkaConsumerRecord<K,V> newInstance(KafkaConsumerRecord arg)
public static <K,V> KafkaConsumerRecord<K,V> newInstance(KafkaConsumerRecord arg, <any> __typeArg_K, <any> __typeArg_V)
Copyright © 2018 Eclipse. All rights reserved.