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 arg)
static <K, V> KafkaConsumerRecords<K,V>	KafkaConsumerRecords.newInstance(io.vertx.kafka.client.consumer.KafkaConsumerRecords arg, TypeArg<K> __typeArg_K, TypeArg<V> __typeArg_V)
KafkaConsumerRecords<K,V>	KafkaConsumer.pollAndAwait(Duration timeout)	Blocking variant of KafkaConsumer.poll(Duration).

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)