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.