Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<KafkaConsumerRecords> |
__TYPE_ARG |
io.vertx.lang.rx.TypeArg<K> |
__typeArg_0 |
io.vertx.lang.rx.TypeArg<V> |
__typeArg_1 |
Constructor and Description |
---|
KafkaConsumerRecords(KafkaConsumerRecords delegate) |
KafkaConsumerRecords(Object delegate,
io.vertx.lang.rx.TypeArg<K> typeArg_0,
io.vertx.lang.rx.TypeArg<V> typeArg_1) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
KafkaConsumerRecords |
getDelegate() |
int |
hashCode() |
boolean |
isEmpty() |
static <K,V> KafkaConsumerRecords<K,V> |
newInstance(KafkaConsumerRecords arg) |
static <K,V> KafkaConsumerRecords<K,V> |
newInstance(KafkaConsumerRecords arg,
io.vertx.lang.rx.TypeArg<K> __typeArg_K,
io.vertx.lang.rx.TypeArg<V> __typeArg_V) |
KafkaConsumerRecord<K,V> |
recordAt(int index)
Get the record at the given index
|
int |
size() |
String |
toString() |
public static final io.vertx.lang.rx.TypeArg<KafkaConsumerRecords> __TYPE_ARG
public final io.vertx.lang.rx.TypeArg<K> __typeArg_0
public final io.vertx.lang.rx.TypeArg<V> __typeArg_1
public KafkaConsumerRecords(KafkaConsumerRecords delegate)
public KafkaConsumerRecords getDelegate()
public int size()
public boolean isEmpty()
public KafkaConsumerRecord<K,V> recordAt(int index)
index
- the index of the record to getpublic static <K,V> KafkaConsumerRecords<K,V> newInstance(KafkaConsumerRecords arg)
public static <K,V> KafkaConsumerRecords<K,V> newInstance(KafkaConsumerRecords arg, io.vertx.lang.rx.TypeArg<K> __typeArg_K, io.vertx.lang.rx.TypeArg<V> __typeArg_V)
Copyright © 2022 Eclipse. All rights reserved.