Uses of Class
io.vertx.mutiny.kafka.client.consumer.KafkaConsumerRecord
Packages that use KafkaConsumerRecord
-
Uses of KafkaConsumerRecord in io.vertx.mutiny.kafka.client.consumer
Fields in io.vertx.mutiny.kafka.client.consumer with type parameters of type KafkaConsumerRecordModifier and TypeFieldDescriptionstatic final TypeArg<KafkaConsumerRecord>
KafkaConsumerRecord.__TYPE_ARG
Methods in io.vertx.mutiny.kafka.client.consumer that return KafkaConsumerRecordModifier and TypeMethodDescriptionstatic <K,
V> KafkaConsumerRecord<K, V> KafkaConsumerRecord.newInstance
(io.vertx.kafka.client.consumer.KafkaConsumerRecord arg) static <K,
V> KafkaConsumerRecord<K, V> KafkaConsumerRecord.newInstance
(io.vertx.kafka.client.consumer.KafkaConsumerRecord arg, TypeArg<K> __typeArg_K, TypeArg<V> __typeArg_V) KafkaConsumerRecords.recordAt
(int index) Methods in io.vertx.mutiny.kafka.client.consumer that return types with arguments of type KafkaConsumerRecordModifier and TypeMethodDescriptionKafkaConsumer.pipe()
KafkaConsumer.toBlockingIterable()
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 KafkaConsumerRecordModifier and TypeMethodDescriptionKafkaConsumer.handler
(Consumer<KafkaConsumerRecord<K, V>> handler) io.smallrye.mutiny.Uni<Void>
KafkaConsumer.pipeTo
(WriteStream<KafkaConsumerRecord<K, V>> dst) KafkaConsumer.pipeToAndAwait
(WriteStream<KafkaConsumerRecord<K, V>> dst) void
KafkaConsumer.pipeToAndForget
(WriteStream<KafkaConsumerRecord<K, V>> dst)