K - the key type.V - the value type.@FunctionalInterface
public interface KafkaFailureCallback<K,V>
extends org.springframework.util.concurrent.FailureCallback
FailureCallback for reporting
KafkaProducerExceptions.| Modifier and Type | Method and Description |
|---|---|
void |
onFailure(KafkaProducerException ex)
Called when the send fails.
|
default void |
onFailure(java.lang.Throwable ex) |
default void onFailure(java.lang.Throwable ex)
onFailure in interface org.springframework.util.concurrent.FailureCallbackvoid onFailure(KafkaProducerException ex)
ex - the exception.