Uses of Class
io.smallrye.reactive.messaging.kafka.IncomingKafkaRecord
-
Packages that use IncomingKafkaRecord Package Description io.smallrye.reactive.messaging.kafka.fault io.smallrye.reactive.messaging.kafka.impl -
-
Uses of IncomingKafkaRecord in io.smallrye.reactive.messaging.kafka.fault
Methods in io.smallrye.reactive.messaging.kafka.fault with parameters of type IncomingKafkaRecord Modifier and Type Method Description <K,V>
CompletionStage<Void>KafkaDeadLetterQueue. handle(IncomingKafkaRecord<K,V> record, Throwable reason)<K,V>
CompletionStage<Void>KafkaFailStop. handle(IncomingKafkaRecord<K,V> record, Throwable reason)<K,V>
CompletionStage<Void>KafkaFailureHandler. handle(IncomingKafkaRecord<K,V> record, Throwable reason)<K,V>
CompletionStage<Void>KafkaIgnoreFailure. handle(IncomingKafkaRecord<K,V> record, Throwable reason) -
Uses of IncomingKafkaRecord in io.smallrye.reactive.messaging.kafka.impl
Methods in io.smallrye.reactive.messaging.kafka.impl that return types with arguments of type IncomingKafkaRecord Modifier and Type Method Description io.smallrye.mutiny.Multi<IncomingKafkaRecord<K,V>>KafkaSource. getStream()
-