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(org.apache.kafka.clients.consumer.ConsumerRecord<K,T> record, KafkaCommitHandler commitHandler, KafkaFailureHandler onNack, boolean cloudEventEnabled, boolean tracingEnabled)
IncomingKafkaRecordBatch(org.apache.kafka.clients.consumer.ConsumerRecords<K,T> records, 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	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(Map<String,?> kafkaConfiguration, KafkaConnectorIncomingConfiguration conf, KafkaSource<?,?> source, KafkaCDIEvents kafkaCDIEvents)