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)
RecordInterceptor
intercept
in interface RecordInterceptor<K,V>
record
- the record.