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

Packages that use KafkaConsumerRecord

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

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

Classes in io.vertx.rxjava3.kafka.client.consumer that implement interfaces with type arguments of type KafkaConsumerRecord

Modifier and Type	Class	Description
class	KafkaConsumer<K,V>	Vert.x Kafka consumer.

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

Modifier and Type	Field	Description
static final io.vertx.lang.rx.TypeArg<KafkaConsumerRecord>	KafkaConsumerRecord.__TYPE_ARG

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

Modifier and Type	Method	Description
static <K,V> KafkaConsumerRecord<K,V>	KafkaConsumerRecord.newInstance(KafkaConsumerRecord arg)
static <K,V> KafkaConsumerRecord<K,V>	KafkaConsumerRecord.newInstance(KafkaConsumerRecord arg, io.vertx.lang.rx.TypeArg<K> __typeArg_K, io.vertx.lang.rx.TypeArg<V> __typeArg_V)
KafkaConsumerRecord<K,V>	KafkaConsumerRecords.recordAt(int index)	Get the record at the given index

Methods in io.vertx.rxjava3.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 to transfer the elements of this stream to a destination .
Flowable<KafkaConsumerRecord<K,V>>	KafkaConsumer.toFlowable()
Observable<KafkaConsumerRecord<K,V>>	KafkaConsumer.toObservable()

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

Modifier and Type	Method	Description
KafkaConsumer<K,V>	KafkaConsumer.handler(Handler<KafkaConsumerRecord<K,V>> handler)
Completable	KafkaConsumer.pipeTo(WriteStream<KafkaConsumerRecord<K,V>> dst)	Pipe this ReadStream to the WriteStream.
Completable	KafkaConsumer.rxPipeTo(WriteStream<KafkaConsumerRecord<K,V>> dst)	Pipe this ReadStream to the WriteStream.