Package org.springframework.kafka.listener

Interface ConsumerAwareRecordRecoverer

  • All Superinterfaces:
    java.util.function.BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecord<?,​?>,​java.lang.Exception>, ConsumerRecordRecoverer
    All Known Implementing Classes:
    DeadLetterPublishingRecoverer
    Functional Interface:
    This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
    @FunctionalInterface
public interface ConsumerAwareRecordRecoverer
extends ConsumerRecordRecoverer
    A ConsumerRecordRecoverer that supports getting a reference to the Consumer.
    Since:
    2.7
    Author:
    Gary Russell

    • Method Summary

      All Methods Instance Methods Abstract Methods Default Methods 
      Modifier and Type Method Description
      default void accept​(org.apache.kafka.clients.consumer.ConsumerRecord<?,​?> record, java.lang.Exception exception)  
      void accept​(org.apache.kafka.clients.consumer.ConsumerRecord<?,​?> record, org.apache.kafka.clients.consumer.Consumer<?,​?> consumer, java.lang.Exception exception)
      Recover the record.

      • Methods inherited from interface java.util.function.BiConsumer

        andThen

    • Method Detail

      • accept

        default void accept​(org.apache.kafka.clients.consumer.ConsumerRecord<?,​?> record,
                    java.lang.Exception exception)
        Specified by:
        accept in interface java.util.function.BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecord<?,​?>,​java.lang.Exception>

      • accept

        void accept​(org.apache.kafka.clients.consumer.ConsumerRecord<?,​?> record,
            @Nullable
            org.apache.kafka.clients.consumer.Consumer<?,​?> consumer,
            java.lang.Exception exception)
        Recover the record.
        Parameters:
        record - the record.
        consumer - the consumer.
        exception - the exception.
        Since:
        2.7