Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<KafkaConsumerRecord> |
__TYPE_ARG |
io.vertx.lang.rx.TypeArg<K> |
__typeArg_0 |
io.vertx.lang.rx.TypeArg<V> |
__typeArg_1 |
Constructor and Description |
---|
KafkaConsumerRecord(KafkaConsumerRecord delegate) |
KafkaConsumerRecord(Object delegate,
io.vertx.lang.rx.TypeArg<K> typeArg_0,
io.vertx.lang.rx.TypeArg<V> 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,
io.vertx.lang.rx.TypeArg<K> __typeArg_K,
io.vertx.lang.rx.TypeArg<V> __typeArg_V) |
long |
offset() |
int |
partition() |
long |
timestamp() |
org.apache.kafka.common.record.TimestampType |
timestampType() |
String |
topic() |
String |
toString() |
V |
value() |
public static final io.vertx.lang.rx.TypeArg<KafkaConsumerRecord> __TYPE_ARG
public final io.vertx.lang.rx.TypeArg<K> __typeArg_0
public final io.vertx.lang.rx.TypeArg<V> __typeArg_1
public KafkaConsumerRecord(KafkaConsumerRecord delegate)
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, io.vertx.lang.rx.TypeArg<K> __typeArg_K, io.vertx.lang.rx.TypeArg<V> __typeArg_V)
Copyright © 2021 Eclipse. All rights reserved.