K
- the key type.V
- the value type.public class CompositeProducerListener<K,V> extends java.lang.Object implements ProducerListener<K,V>
ProducerListener
that delegates to a collection of listeners.Constructor and Description |
---|
CompositeProducerListener(ProducerListener<K,V>... delegates) |
Modifier and Type | Method and Description |
---|---|
void |
addDelegate(ProducerListener<K,V> delegate) |
protected java.util.List<ProducerListener<K,V>> |
getDelegates() |
void |
onError(org.apache.kafka.clients.producer.ProducerRecord<K,V> producerRecord,
java.lang.Exception exception)
Invoked after an attempt to send a message has failed.
|
void |
onSuccess(org.apache.kafka.clients.producer.ProducerRecord<K,V> producerRecord,
org.apache.kafka.clients.producer.RecordMetadata recordMetadata)
Invoked after the successful send of a message (that is, after it has been acknowledged by the broker).
|
boolean |
removeDelegate(ProducerListener<K,V> delegate) |
void |
setDelegates(ProducerListener<K,V>... delegates) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isInterestedInSuccess, onError, onSuccess
@SafeVarargs public CompositeProducerListener(ProducerListener<K,V>... delegates)
@SafeVarargs public final void setDelegates(ProducerListener<K,V>... delegates)
protected java.util.List<ProducerListener<K,V>> getDelegates()
public void addDelegate(ProducerListener<K,V> delegate)
public boolean removeDelegate(ProducerListener<K,V> delegate)
public void onSuccess(org.apache.kafka.clients.producer.ProducerRecord<K,V> producerRecord, org.apache.kafka.clients.producer.RecordMetadata recordMetadata)
ProducerListener
onSuccess
in interface ProducerListener<K,V>
producerRecord
- the actual sent recordrecordMetadata
- the result of the successful send operationpublic void onError(org.apache.kafka.clients.producer.ProducerRecord<K,V> producerRecord, java.lang.Exception exception)
ProducerListener
onError
in interface ProducerListener<K,V>
producerRecord
- the failed recordexception
- the exception thrown