Package org.springframework.kafka.listener

Class DefaultAfterRollbackProcessor<K,​V>

  • Type Parameters:
    K - the key type.
    V - the value type.
    All Implemented Interfaces:
    org.springframework.beans.factory.InitializingBean, AfterRollbackProcessor<K,​V>, DeliveryAttemptAware
    public class DefaultAfterRollbackProcessor<K,​V>
extends FailedRecordProcessor
implements AfterRollbackProcessor<K,​V>, org.springframework.beans.factory.InitializingBean
    Default implementation of AfterRollbackProcessor. Seeks all topic/partitions so the records will be re-fetched, including the failed record. Starting with version 2.2 after a configurable number of failures for the same topic/partition/offset, that record will be skipped after calling a BiConsumer recoverer. The default recoverer simply logs the failed record.
    Since:
    1.3.5
    Author:
    Gary Russell

    • Constructor Detail

      • DefaultAfterRollbackProcessor

        public DefaultAfterRollbackProcessor()
        Construct an instance with the default recoverer which simply logs the record after 10 (maxFailures) have occurred for a topic/partition/offset.
        Since:
        2.2

      • DefaultAfterRollbackProcessor

        public DefaultAfterRollbackProcessor​(org.springframework.util.backoff.BackOff backOff)
        Construct an instance with the default recoverer which simply logs the record after the backOff returns STOP for a topic/partition/offset.
        Parameters:
        backOff - the BackOff.
        Since:
        2.3

      • DefaultAfterRollbackProcessor

        public DefaultAfterRollbackProcessor​(java.util.function.BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecord<?,​?>,​java.lang.Exception> recoverer)
        Construct an instance with the provided recoverer which will be called after 10 (maxFailures) have occurred for a topic/partition/offset.
        Parameters:
        recoverer - the recoverer.
        Since:
        2.2

      • DefaultAfterRollbackProcessor

        public DefaultAfterRollbackProcessor​(@Nullable
                                     java.util.function.BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecord<?,​?>,​java.lang.Exception> recoverer,
                                     org.springframework.util.backoff.BackOff backOff)
        Construct an instance with the provided recoverer which will be called after the backOff returns STOP for a topic/partition/offset.
        Parameters:
        recoverer - the recoverer; if null, the default (logging) recoverer is used.
        backOff - the BackOff.
        Since:
        2.3

      • DefaultAfterRollbackProcessor

        public DefaultAfterRollbackProcessor​(@Nullable
                                     java.util.function.BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecord<?,​?>,​java.lang.Exception> recoverer,
                                     org.springframework.util.backoff.BackOff backOff,
                                     @Nullable
                                     KafkaOperations<?,​?> kafkaOperations,
                                     boolean commitRecovered)
        Construct an instance with the provided recoverer which will be called after the backOff returns STOP for a topic/partition/offset.
        Parameters:
        recoverer - the recoverer; if null, the default (logging) recoverer is used.
        backOff - the BackOff.
        kafkaOperations - for sending the recovered offset to the transaction.
        commitRecovered - true to commit the recovered record's offset; requires a KafkaOperations.
        Since:
        2.5.3