org.springframework.kafka.listener

Interface ConsumerAwareErrorHandler

All Superinterfaces:

ErrorHandler, GenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>

All Known Subinterfaces:

ContainerAwareErrorHandler, RemainingRecordsErrorHandler

All Known Implementing Classes:

ContainerStoppingErrorHandler, SeekToCurrentErrorHandler

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 ConsumerAwareErrorHandler
extends ErrorHandler

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 and Description
default void	handle(java.lang.Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecord<?,?> data) Handle the exception.
void	handle(java.lang.Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecord<?,?> data, org.apache.kafka.clients.consumer.Consumer<?,?> consumer) Handle the exception.
default void	handle(java.lang.Exception thrownException, java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> data, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, MessageListenerContainer container) Handle the exception.

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

clearThreadState, isAckAfterHandle

Method Detail

handle

default void handle(java.lang.Exception thrownException,
                    org.apache.kafka.clients.consumer.ConsumerRecord<?,?> data)

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(java.lang.Exception thrownException,
            org.apache.kafka.clients.consumer.ConsumerRecord<?,?> data,
            org.apache.kafka.clients.consumer.Consumer<?,?> consumer)

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(java.lang.Exception thrownException,
                    java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> data,
                    org.apache.kafka.clients.consumer.Consumer<?,?> consumer,
                    MessageListenerContainer container)

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.