K
- the key type.V
- the value type.public class LoggingProducerListener<K,V> extends java.lang.Object implements ProducerListener<K,V>
ProducerListener
that logs exceptions thrown when sending messages.Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_MAX_CONTENT_LOGGED
Default max content logged.
|
Constructor and Description |
---|
LoggingProducerListener() |
Modifier and Type | Method and Description |
---|---|
void |
onError(org.apache.kafka.clients.producer.ProducerRecord<K,V> record,
java.lang.Exception exception)
Invoked after an attempt to send a message has failed.
|
void |
setIncludeContents(boolean includeContents)
Whether the log message should include the contents (key and payload).
|
void |
setMaxContentLogged(int maxContentLogged)
The maximum amount of data to be logged for either key or password.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isInterestedInSuccess, onError, onSuccess, onSuccess
public static final int DEFAULT_MAX_CONTENT_LOGGED
public void setIncludeContents(boolean includeContents)
includeContents
- true if the contents of the message should be loggedpublic void setMaxContentLogged(int maxContentLogged)
maxContentLogged
- the maximum amount of data being logged.public void onError(org.apache.kafka.clients.producer.ProducerRecord<K,V> record, java.lang.Exception exception)
ProducerListener
onError
in interface ProducerListener<K,V>
record
- the failed recordexception
- the exception thrown