Package org.springframework.kafka.listener

Class LoggingCommitCallback

  • All Implemented Interfaces:
    org.apache.kafka.clients.consumer.OffsetCommitCallback
    public final class LoggingCommitCallback
extends java.lang.Object
implements org.apache.kafka.clients.consumer.OffsetCommitCallback
    Logs commit results at DEBUG level for success and ERROR for failures.
    Since:
    2.2.4
    Author:
    Gary Russell

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void onComplete​(java.util.Map<org.apache.kafka.common.TopicPartition,​org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets, java.lang.Exception exception)  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • LoggingCommitCallback

        public LoggingCommitCallback()

    • Method Detail

      • onComplete

        public void onComplete​(java.util.Map<org.apache.kafka.common.TopicPartition,​org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets,
                       java.lang.Exception exception)
        Specified by:
        onComplete in interface org.apache.kafka.clients.consumer.OffsetCommitCallback