ConsumerAwareListenerErrorHandler (Spring Kafka 2.6.13 API)

All Superinterfaces:

KafkaListenerErrorHandler

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 ConsumerAwareListenerErrorHandler
extends KafkaListenerErrorHandler
```
An error handler that has access to the consumer. IMPORTANT: do not perform seek operations on the consumer, the container won't be aware. Use a container-level error handler such as the SeekToCurrentErrorHandler for such situations.

Since:

2.0

Author:

Gary Russell

Method Summary

All Methods Instance Methods Abstract Methods Default Methods
Modifier and Type	Method	Description
`default java.lang.Object`	`handleError(org.springframework.messaging.Message<?> message, ListenerExecutionFailedException exception)`	Handle the error.
`java.lang.Object`	`handleError(org.springframework.messaging.Message<?> message, ListenerExecutionFailedException exception, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)`	Handle the error.

- Method Detail
  - handleError
```
default java.lang.Object handleError(org.springframework.messaging.Message<?> message,
                                     ListenerExecutionFailedException exception)
```
    Description copied from interface: KafkaListenerErrorHandler
    
    Handle the error.
    
    Specified by:
    
    handleError in interface KafkaListenerErrorHandler
    
    Parameters:
    
    message - the spring-messaging message.
    
    exception - the exception the listener threw, wrapped in a ListenerExecutionFailedException.
    
    Returns:
    
    the return value is ignored unless the annotated method has a @SendTo annotation.
  - handleError
```
java.lang.Object handleError(org.springframework.messaging.Message<?> message,
                             ListenerExecutionFailedException exception,
                             org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
```
    Description copied from interface: KafkaListenerErrorHandler
    
    Handle the error.
    
    Specified by:
    
    handleError in interface KafkaListenerErrorHandler
    
    Parameters:
    
    message - the spring-messaging message.
    
    exception - the exception the listener threw, wrapped in a ListenerExecutionFailedException.
    
    consumer - the consumer.
    
    Returns:
    
    the return value is ignored unless the annotated method has a @SendTo annotation.