Uses of Interface
io.smallrye.reactive.messaging.kafka.fault.KafkaFailureHandler

Packages that use KafkaFailureHandler

Package	Description
io.smallrye.reactive.messaging.kafka
io.smallrye.reactive.messaging.kafka.fault

Uses of KafkaFailureHandler in io.smallrye.reactive.messaging.kafka

Constructors in io.smallrye.reactive.messaging.kafka with parameters of type KafkaFailureHandler

Constructor	Description
IncomingKafkaRecord(io.vertx.mutiny.kafka.client.consumer.KafkaConsumer<K,T> consumer, io.vertx.mutiny.kafka.client.consumer.KafkaConsumerRecord<K,T> record, KafkaFailureHandler onNack)

Uses of KafkaFailureHandler in io.smallrye.reactive.messaging.kafka.fault

Classes in io.smallrye.reactive.messaging.kafka.fault that implement KafkaFailureHandler

Modifier and Type	Class	Description
class	KafkaDeadLetterQueue
class	KafkaFailStop
class	KafkaIgnoreFailure

Methods in io.smallrye.reactive.messaging.kafka.fault that return KafkaFailureHandler

Modifier and Type	Method	Description
static KafkaFailureHandler	KafkaDeadLetterQueue.create(io.vertx.mutiny.core.Vertx vertx, Map<String,String> kafkaConfiguration, KafkaConnectorIncomingConfiguration conf, KafkaSource<?,?> source)