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, onFailure

    Methods inherited from interface org.springframework.util.concurrent.SuccessCallback

    onSuccess