K
- the key type.V
- the value type.@FunctionalInterface
public interface KafkaFailureCallback<K,V>
extends org.springframework.util.concurrent.FailureCallback
FailureCallback
for reporting
KafkaProducerException
s.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.FailureCallback
void onFailure(KafkaProducerException ex)
ex
- the exception.