RecordInterceptor (Spring Kafka 2.6.8 API)

Type Parameters:

K - the key type.

V - the value type.

All Known Implementing Classes:

CompositeRecordInterceptor

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 RecordInterceptor<K,V>
```
An interceptor for ConsumerRecord invoked by the listener container before and after invoking the listener.

Since:

2.2.7

Author:

Gary Russell

Method Summary

All Methods Instance Methods Abstract Methods Default Methods
Modifier and Type	Method	Description
`default void`	`failure(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record, java.lang.Exception exception)`	Called after the listener throws an exception.
`org.apache.kafka.clients.consumer.ConsumerRecord<K,V>`	`intercept(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)`	Perform some action on the record or return a different one.
`default void`	`success(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)`	Called after the listener exits normally.

- Method Detail
  - intercept
```
@Nullable
org.apache.kafka.clients.consumer.ConsumerRecord<K,V> intercept(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)
```
    Perform some action on the record or return a different one. If null is returned the record will be skipped. Invoked before the listener.
    
    Parameters:
    
    record - the record.
    
    Returns:
    
    the record or null.
  - success
```
default void success(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)
```
    Called after the listener exits normally.
    
    Parameters:
    
    record - the record.
    
    Since:
    
    2.6.8
  - failure
```
default void failure(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record,
                     java.lang.Exception exception)
```
    Called after the listener throws an exception.
    
    Parameters:
    
    record - the record.
    
    exception - the exception.
    
    Since:
    
    2.6.8