Class CompositeProducerListener<K,​V>

  • Type Parameters:
    K - the key type.
    V - the value type.
    All Implemented Interfaces:
    ProducerListener<K,​V>

    public class CompositeProducerListener<K,​V>
    extends java.lang.Object
    implements ProducerListener<K,​V>
    A ProducerListener that delegates to a collection of listeners.
    Since:
    2.1.6
    • Constructor Detail

      • CompositeProducerListener

        @SafeVarargs
        public CompositeProducerListener​(ProducerListener<K,​V>... delegates)
    • Method Detail

      • setDelegates

        @SafeVarargs
        public final void setDelegates​(ProducerListener<K,​V>... delegates)
      • onSuccess

        public void onSuccess​(org.apache.kafka.clients.producer.ProducerRecord<K,​V> producerRecord,
                              org.apache.kafka.clients.producer.RecordMetadata recordMetadata)
        Description copied from interface: ProducerListener
        Invoked after the successful send of a message (that is, after it has been acknowledged by the broker).
        Specified by:
        onSuccess in interface ProducerListener<K,​V>
        Parameters:
        producerRecord - the actual sent record
        recordMetadata - the result of the successful send operation
      • onError

        public void onError​(org.apache.kafka.clients.producer.ProducerRecord<K,​V> producerRecord,
                            java.lang.Exception exception)
        Description copied from interface: ProducerListener
        Invoked after an attempt to send a message has failed.
        Specified by:
        onError in interface ProducerListener<K,​V>
        Parameters:
        producerRecord - the failed record
        exception - the exception thrown