Uses of Class
io.vertx.reactivex.kafka.client.consumer.KafkaConsumerRecords

Packages that use KafkaConsumerRecords

Package	Description
io.vertx.reactivex.kafka.client.consumer

Uses of KafkaConsumerRecords in io.vertx.reactivex.kafka.client.consumer

Fields in io.vertx.reactivex.kafka.client.consumer with type parameters of type KafkaConsumerRecords

Modifier and Type	Field and Description
static io.vertx.lang.rx.TypeArg<KafkaConsumerRecords>	KafkaConsumerRecords.__TYPE_ARG

Methods in io.vertx.reactivex.kafka.client.consumer that return KafkaConsumerRecords

Modifier and Type	Method and Description
static <K,V> KafkaConsumerRecords<K,V>	KafkaConsumerRecords.newInstance(KafkaConsumerRecords arg)
static <K,V> KafkaConsumerRecords<K,V>	KafkaConsumerRecords.newInstance(KafkaConsumerRecords arg, io.vertx.lang.rx.TypeArg<K> __typeArg_K, io.vertx.lang.rx.TypeArg<V> __typeArg_V)

Methods in io.vertx.reactivex.kafka.client.consumer that return types with arguments of type KafkaConsumerRecords

Modifier and Type	Method and Description
Single<KafkaConsumerRecords<K,V>>	KafkaConsumer.rxPoll(java.time.Duration timeout) Executes a poll for getting messages from Kafka.

Method parameters in io.vertx.reactivex.kafka.client.consumer with type arguments of type KafkaConsumerRecords

Modifier and Type	Method and Description
KafkaConsumer<K,V>	KafkaConsumer.batchHandler(Handler<KafkaConsumerRecords<K,V>> handler) Set the handler to be used when batches of messages are fetched from the Kafka server.
void	KafkaConsumer.poll(java.time.Duration timeout, Handler<AsyncResult<KafkaConsumerRecords<K,V>>> handler) Executes a poll for getting messages from Kafka.