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
io.vertx.rxjava3.kafka.client.consumer

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

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

Modifier and Type	Method and Description
Future<KafkaConsumerRecords<K,V>>	KafkaConsumer.poll(java.time.Duration timeout) Like KafkaConsumer.poll(Duration, Handler) but returns a Future of the asynchronous result

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(java.time.Duration 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)

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

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

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

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

Constructor and Description
KafkaConsumerRecords(KafkaConsumerRecords delegate)