Package org.springframework.kafka.support

Class CompositeProducerListener<K,V>

java.lang.Object

org.springframework.kafka.support.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 Object
implements ProducerListener<K,V>

A ProducerListener that delegates to a collection of listeners.

Since:

2.1.6

Author:

Gary Russell, Artem Bilan

Constructor Summary

Constructors

Constructor	Description
CompositeProducerListener(ProducerListener<K,V>... delegates)

Method Summary

Modifier and Type	Method	Description
void	addDelegate(ProducerListener<K,V> delegate)
protected List<ProducerListener<K,V>>	getDelegates()
void	onError(org.apache.kafka.clients.producer.ProducerRecord<K,V> producerRecord, org.apache.kafka.clients.producer.RecordMetadata recordMetadata, 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)
final void	setDelegates(ProducerListener<K,V>... delegates)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CompositeProducerListener

@SafeVarargs
public CompositeProducerListener(ProducerListener<K,V>... delegates)

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>

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

Parameters:

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