K - the key type.V - the value type.public class CompositeRecordInterceptor<K,V> extends java.lang.Object implements RecordInterceptor<K,V>
RecordInterceptor that delegates to one or more RecordInterceptor in
order.| Constructor and Description |
|---|
CompositeRecordInterceptor(RecordInterceptor<K,V>... delegates) |
| 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.
|
@SafeVarargs public CompositeRecordInterceptor(RecordInterceptor<K,V>... delegates)
public org.apache.kafka.clients.consumer.ConsumerRecord<K,V> intercept(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)
RecordInterceptorintercept in interface RecordInterceptor<K,V>record - the record.