org.springframework.kafka.support

Class ProducerListenerAdapter<K,V>

java.lang.Object

org.springframework.kafka.support.ProducerListenerAdapter<K,V>

Type Parameters:

K - the key type.

V - the value type.

All Implemented Interfaces:

ProducerListener<K,V>

Direct Known Subclasses:

LoggingProducerListener

public abstract class ProducerListenerAdapter<K,V>
extends java.lang.Object
implements ProducerListener<K,V>

No-op implementation of ProducerListener, to be used as base class for other implementations.

Author:

Marius Bogoevici, Gary Russell, Artem Bilan

Constructor Summary

Constructors

Constructor and Description
ProducerListenerAdapter()

Method Summary

Modifier and Type	Method and Description
boolean	isInterestedInSuccess() Return true if this listener is interested in success as well as failure.
void	onError(java.lang.String topic, java.lang.Integer partition, K key, V value, java.lang.Exception exception) Invoked after an attempt to send a message has failed.
void	onSuccess(java.lang.String topic, java.lang.Integer partition, K key, V value, 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).

Methods inherited from class java.lang.Object

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

Constructor Detail

ProducerListenerAdapter

public ProducerListenerAdapter()

Method Detail

onSuccess

public void onSuccess(java.lang.String topic,
                      java.lang.Integer partition,
                      K key,
                      V value,
                      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:

topic - the destination topic

partition - the destination partition (could be null)

key - the key of the outbound message

value - the payload of the outbound message

recordMetadata - the result of the successful send operation

onError

public void onError(java.lang.String topic,
                    java.lang.Integer partition,
                    K key,
                    V value,
                    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:

topic - the destination topic

partition - the destination partition (could be null)

key - the key of the outbound message

value - the payload of the outbound message

exception - the exception thrown

isInterestedInSuccess

public boolean isInterestedInSuccess()

Description copied from interface: ProducerListener

Return true if this listener is interested in success as well as failure.

Specified by:

isInterestedInSuccess in interface ProducerListener<K,V>

Returns:

true to express interest in successful sends.