Package org.springframework.kafka.listener

Interface ConsumerAwareErrorHandler

All Superinterfaces:
ErrorHandler, GenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>
All Known Subinterfaces:
ContainerAwareErrorHandler, RemainingRecordsErrorHandler
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@Deprecated @FunctionalInterface public interface ConsumerAwareErrorHandler extends ErrorHandler
Deprecated.
in favor of CommonErrorHandler.
An error handler that has access to the consumer, for example to adjust offsets after an error.
Since:
2.0
Author:
Gary Russell

  • Method Summary

    Modifier and Type
    Method
    Description
    default void
    handle(Exception thrownException, List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> data, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, MessageListenerContainer container)
    Deprecated.
    Handle the exception.
    default void
    handle(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecord<?,?> data)
    Deprecated.
    Handle the exception.
    void
    handle(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecord<?,?> data, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
    Deprecated.
    Handle the exception.

    Methods inherited from interface org.springframework.kafka.listener.GenericErrorHandler

    clearThreadState, isAckAfterHandle, setAckAfterHandle

  • Method Details

    • handle

      default void handle(Exception thrownException, @Nullable org.apache.kafka.clients.consumer.ConsumerRecord<?,?> data)
      Deprecated.
      Description copied from interface: GenericErrorHandler
      Handle the exception.
      Specified by:
      handle in interface GenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>
      Parameters:
      thrownException - The exception.
      data - the data.

    • handle

      void handle(Exception thrownException, @Nullable org.apache.kafka.clients.consumer.ConsumerRecord<?,?> data, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
      Deprecated.
      Description copied from interface: GenericErrorHandler
      Handle the exception.
      Specified by:
      handle in interface GenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>
      Parameters:
      thrownException - The exception.
      data - the data.
      consumer - the consumer.

    • handle

      default void handle(Exception thrownException, @Nullable List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> data, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, MessageListenerContainer container)
      Deprecated.
      Description copied from interface: ErrorHandler
      Handle the exception.
      Specified by:
      handle in interface ErrorHandler
      Parameters:
      thrownException - the exception.
      data - the remaining records including the one that failed.
      consumer - the consumer.
      container - the container.