Package org.springframework.kafka.support

Class LoggingProducerListener<K,​V>

  • Type Parameters:
    K - the key type.
    V - the value type.
    All Implemented Interfaces:
    ProducerListener<K,​V>
    public class LoggingProducerListener<K,​V>
extends java.lang.Object
implements ProducerListener<K,​V>
    The ProducerListener that logs exceptions thrown when sending messages.
    Author:
    Marius Bogoevici, Gary Russell

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method 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.

      • Methods inherited from class java.lang.Object

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

    • Field Detail

      • DEFAULT_MAX_CONTENT_LOGGED

        public static final int DEFAULT_MAX_CONTENT_LOGGED
        Default max content logged.
        See Also:
        Constant Field Values

    • Constructor Detail

      • LoggingProducerListener

        public LoggingProducerListener()

    • Method Detail

      • setIncludeContents

        public void setIncludeContents​(boolean includeContents)
        Whether the log message should include the contents (key and payload).
        Parameters:
        includeContents - true if the contents of the message should be logged

      • setMaxContentLogged

        public void setMaxContentLogged​(int maxContentLogged)
        The maximum amount of data to be logged for either key or password. As message sizes may vary and become fairly large, this allows limiting the amount of data sent to logs. Default 100.
        Parameters:
        maxContentLogged - the maximum amount of data being logged.

      • onError

        public void onError​(org.apache.kafka.clients.producer.ProducerRecord<K,​V> record,
                    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:
        record - the failed record
        exception - the exception thrown