Package org.springframework.kafka.core
Interface KafkaSendCallback<K,V>
- Type Parameters:
K- the key type.V- the value type.
- All Superinterfaces:
org.springframework.util.concurrent.FailureCallback,KafkaFailureCallback<K,,V> org.springframework.util.concurrent.ListenableFutureCallback<SendResult<K,,V>> org.springframework.util.concurrent.SuccessCallback<SendResult<K,V>>
public interface KafkaSendCallback<K,V>
extends org.springframework.util.concurrent.ListenableFutureCallback<SendResult<K,V>>, KafkaFailureCallback<K,V>
An enhanced
ListenableFutureCallback for reporting
KafkaProducerExceptions.- Since:
- 2.5
-
Method Summary
Methods inherited from interface org.springframework.kafka.core.KafkaFailureCallback
onFailure, onFailureMethods inherited from interface org.springframework.util.concurrent.SuccessCallback
onSuccess