Class CompositeProducerListener<K,V>

Type Parameters:
K - the key type.
V - the value type.
All Implemented Interfaces:

public class CompositeProducerListener<K,V> extends Object implements ProducerListener<K,V>
A ProducerListener that delegates to a collection of listeners.
Gary Russell, Artem Bilan
  • Constructor Details

  • Method Details

    • setDelegates

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

      protected List<ProducerListener<K,V>> getDelegates()
    • addDelegate

      public void addDelegate(ProducerListener<K,V> delegate)
    • removeDelegate

      public boolean removeDelegate(ProducerListener<K,V> delegate)
    • 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>
      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, org.apache.kafka.clients.producer.RecordMetadata recordMetadata, 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>
      producerRecord - the failed record
      recordMetadata - The metadata for the record that was sent (i.e. the partition and offset). If an error occurred, metadata will contain only valid topic and maybe the partition. If the partition is not provided in the ProducerRecord and an error occurs before partition is assigned, then the partition will be set to RecordMetadata.UNKNOWN_PARTITION.
      exception - the exception thrown