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 and Description
IncomingKafkaRecord(org.apache.kafka.clients.consumer.ConsumerRecord<K,T> record, KafkaCommitHandler commitHandler, KafkaFailureHandler onNack, boolean cloudEventEnabled, boolean tracingEnabled)

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 and Description
class	KafkaDeadLetterQueue
class	KafkaFailStop
class	KafkaIgnoreFailure

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

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