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

Packages that use KafkaConsumerRecord

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

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

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

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

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

Modifier and Type	Method	Description
static <K, V> KafkaConsumerRecord<K,V>	KafkaConsumerRecord.newInstance(io.vertx.kafka.client.consumer.KafkaConsumerRecord<K,V> delegate)	Creates a new instance of the KafkaConsumerRecord.
static <K, V> KafkaConsumerRecord<K,V>	KafkaConsumerRecord.newInstance(io.vertx.kafka.client.consumer.KafkaConsumerRecord<K,V> delegate, TypeArg<K> typeArg_0, TypeArg<V> typeArg_1)	Creates a new instance of the KafkaConsumerRecord.
KafkaConsumerRecord<K,V>	KafkaConsumerRecords.recordAt(int index)	Get the record at the given index

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

Modifier and Type	Method	Description
Pipe<KafkaConsumerRecord<K,V>>	KafkaConsumer.pipe()	Pause this stream and return a Pipe to transfer the elements of this stream to a destination WriteStream.
Iterable<KafkaConsumerRecord<K,V>>	KafkaConsumer.toBlockingIterable()
Stream<KafkaConsumerRecord<K,V>>	KafkaConsumer.toBlockingStream()
io.smallrye.mutiny.Multi<KafkaConsumerRecord<K,V>>	KafkaConsumer.toMulti()

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

Modifier and Type	Method	Description
KafkaConsumer<K,V>	KafkaConsumer.handler(Consumer<KafkaConsumerRecord<K,V>> handler)
io.smallrye.mutiny.Uni<Void>	KafkaConsumer.pipeTo(WriteStream<KafkaConsumerRecord<K,V>> dst)	Pipe this ReadStream to the WriteStream.
void	KafkaConsumer.pipeToAndAwait(WriteStream<KafkaConsumerRecord<K,V>> dst)	Pipe this ReadStream to the WriteStream.
KafkaConsumer<K,V>	KafkaConsumer.pipeToAndForget(WriteStream<KafkaConsumerRecord<K,V>> dst)	Pipe this ReadStream to the WriteStream.