| Package | Description |
|---|---|
| io.vertx.rxjava.kafka.client.consumer |
| Modifier and Type | Method and Description |
|---|---|
static <K,V> KafkaConsumerRecord<K,V> |
KafkaConsumerRecord.newInstance(KafkaConsumerRecord arg) |
static <K,V> KafkaConsumerRecord<K,V> |
KafkaConsumerRecord.newInstance(KafkaConsumerRecord arg,
<any> __typeArg_K,
<any> __typeArg_V) |
KafkaConsumerRecord<K,V> |
KafkaConsumerRecords.recordAt(int index)
Get the record at the given index
|
| Modifier and Type | Method and Description |
|---|---|
ReadStream<KafkaConsumerRecord<K,V>> |
KafkaConsumer.fetch(long amount)
Fetch the specified
amount of elements. |
Observable<KafkaConsumerRecord<K,V>> |
KafkaConsumer.toObservable() |
| Modifier and Type | Method and Description |
|---|---|
KafkaConsumer<K,V> |
KafkaConsumer.handler(Handler<KafkaConsumerRecord<K,V>> handler) |
Copyright © 2018 Eclipse. All rights reserved.