Package org.springframework.kafka.listener

Interface ConsumerAwareRecordRecoverer

All Superinterfaces:
BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>,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

    Modifier and Type
    Method
    Description
    default void
    accept(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, Exception exception)
     
    void
    accept(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, Exception exception)
    Recover the record.

    Methods inherited from interface java.util.function.BiConsumer

    andThen

  • Method Details

    • accept

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

    • accept

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