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>>
    @Deprecated
public interface KafkaSendCallback<K,​V>
extends org.springframework.util.concurrent.ListenableFutureCallback<SendResult<K,​V>>, KafkaFailureCallback<K,​V>
    Deprecated.
    as of 2.9.1, in favor of CompletableFuture.whenComplete(BiConsumer)
    An enhanced ListenableFutureCallback for reporting KafkaProducerExceptions.
    Since:
    2.5
    Author:
    Gary Russell

    • Method Summary

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

        onSuccess