KafkaFailureHandler (SmallRye Reactive Messaging 2.7.1 API)

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

All Methods Instance Methods Abstract Methods Default Methods
Modifier and Type	Method	Description
`<K,V> CompletionStage<Void>`	`handle(IncomingKafkaRecord<K,V> record, Throwable reason)`
`default void`	`terminate()`

Method Detail

handle

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

terminate
```
default void terminate()
```