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

Interface KafkaFailureHandler

All Known Implementing Classes:

KafkaDeadLetterQueue, KafkaFailStop, KafkaIgnoreFailure

public interface KafkaFailureHandler

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	KafkaFailureHandler.Strategy

Method Summary

Modifier and Type	Method	Description
<K,V> CompletionStage<Void>	handle(IncomingKafkaRecord<K,V> record, Throwable reason, Metadata metadata)
default void	terminate()

Method Detail

handle

<K,V> CompletionStage<Void> handle(IncomingKafkaRecord<K,V> record,
                                         Throwable reason,
                                         Metadata metadata)

terminate

default void terminate()