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

Packages that use KafkaConsumerRecords

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

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

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

Modifier and Type	Field	Description
static final TypeArg<KafkaConsumerRecords>	KafkaConsumerRecords.__TYPE_ARG

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

Modifier and Type	Method	Description
static <K, V> KafkaConsumerRecords<K,V>	KafkaConsumerRecords.newInstance(io.vertx.kafka.client.consumer.KafkaConsumerRecords<K,V> delegate)	Creates a new instance of the KafkaConsumerRecords.
static <K, V> KafkaConsumerRecords<K,V>	KafkaConsumerRecords.newInstance(io.vertx.kafka.client.consumer.KafkaConsumerRecords<K,V> delegate, TypeArg<K> typeArg_0, TypeArg<V> typeArg_1)	Creates a new instance of the KafkaConsumerRecords.
KafkaConsumerRecords<K,V>	KafkaConsumer.pollAndAwait(Duration timeout)	Executes a poll for getting messages from Kafka.

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

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<KafkaConsumerRecords<K,V>>	KafkaConsumer.poll(Duration timeout)	Executes a poll for getting messages from Kafka.

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

Modifier and Type	Method	Description
KafkaConsumer<K,V>	KafkaConsumer.batchHandler(Consumer<KafkaConsumerRecords<K,V>> handler)	Set the handler to be used when batches of messages are fetched from the Kafka server.