K
- the key type.V
- the value type.@FunctionalInterface
public interface RecordInterceptor<K,V>
ConsumerRecord
invoked by the listener
container before invoking the listener.Modifier and Type | Method and Description |
---|---|
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.
|
@Nullable org.apache.kafka.clients.consumer.ConsumerRecord<K,V> intercept(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)
record
- the record.