Class KafkaConsumerRecords<K,V>
- java.lang.Object
-
- io.vertx.rxjava3.kafka.client.consumer.KafkaConsumerRecords<K,V>
-
-
Field Summary
Fields Modifier and Type Field Description static io.vertx.lang.rx.TypeArg<KafkaConsumerRecords>__TYPE_ARGio.vertx.lang.rx.TypeArg<K>__typeArg_0io.vertx.lang.rx.TypeArg<V>__typeArg_1
-
Constructor Summary
Constructors Constructor Description KafkaConsumerRecords(KafkaConsumerRecords delegate)KafkaConsumerRecords(Object delegate, io.vertx.lang.rx.TypeArg<K> typeArg_0, io.vertx.lang.rx.TypeArg<V> typeArg_1)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(Object o)KafkaConsumerRecordsgetDelegate()inthashCode()booleanisEmpty()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 indexintsize()StringtoString()
-
-
-
Field Detail
-
__TYPE_ARG
public static final io.vertx.lang.rx.TypeArg<KafkaConsumerRecords> __TYPE_ARG
-
__typeArg_0
public final io.vertx.lang.rx.TypeArg<K> __typeArg_0
-
__typeArg_1
public final io.vertx.lang.rx.TypeArg<V> __typeArg_1
-
-
Constructor Detail
-
KafkaConsumerRecords
public KafkaConsumerRecords(KafkaConsumerRecords delegate)
-
-
Method Detail
-
getDelegate
public KafkaConsumerRecords getDelegate()
- Specified by:
getDelegatein interfaceio.vertx.lang.rx.RxDelegate
-
size
public int size()
- Returns:
- the total number of records in this batch
-
isEmpty
public boolean isEmpty()
- Returns:
- whether this batch contains any records
-
recordAt
public KafkaConsumerRecord<K,V> recordAt(int index)
Get the record at the given index- Parameters:
index- the index of the record to get- Returns:
-
newInstance
public static <K,V> KafkaConsumerRecords<K,V> newInstance(KafkaConsumerRecords arg)
-
newInstance
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)
-
-