Uses of Interface
io.vertx.kafka.client.consumer.KafkaConsumerRecords

Packages that use KafkaConsumerRecords

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

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

Method parameters in io.vertx.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(long timeout, Handler<AsyncResult<KafkaConsumerRecords<K,V>>> handler) Executes a poll for getting messages from Kafka

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

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

Modifier and Type	Method and Description
KafkaConsumerRecords	KafkaConsumerRecords.getDelegate()

Methods in io.vertx.reactivex.kafka.client.consumer with parameters of type 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)

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

Constructor and Description
KafkaConsumerRecords(KafkaConsumerRecords delegate)

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

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

Modifier and Type	Method and Description
KafkaConsumerRecords	KafkaConsumerRecords.getDelegate()

Methods in io.vertx.rxjava.kafka.client.consumer with parameters of type 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)

Constructors in io.vertx.rxjava.kafka.client.consumer with parameters of type KafkaConsumerRecords

Constructor and Description
KafkaConsumerRecords(KafkaConsumerRecords delegate)