public interface KafkaFailureHandler
Modifier and Type | Interface and Description |
---|---|
static class |
KafkaFailureHandler.Strategy |
Modifier and Type | Method and Description |
---|---|
<K,V> CompletionStage<Void> |
handle(IncomingKafkaRecord<K,V> record,
Throwable reason) |
default void |
terminate() |
<K,V> CompletionStage<Void> handle(IncomingKafkaRecord<K,V> record, Throwable reason)
default void terminate()
Copyright © 2018–2021 SmallRye. All rights reserved.