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_ARGMethods 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) voidKafkaConsumer.pipeToAndForget(WriteStream<KafkaConsumerRecord<K, V>> dst)