Class CompositeRecordInterceptor<K,V>
- java.lang.Object
-
- org.springframework.kafka.listener.CompositeRecordInterceptor<K,V>
-
- Type Parameters:
K- the key type.V- the value type.
- All Implemented Interfaces:
RecordInterceptor<K,V>
public class CompositeRecordInterceptor<K,V> extends java.lang.Object implements RecordInterceptor<K,V>
ARecordInterceptorthat delegates to one or moreRecordInterceptors in order.- Since:
- 2.3
-
-
Constructor Summary
Constructors Constructor Description CompositeRecordInterceptor(RecordInterceptor<K,V>... delegates)Construct an instance with the provided delegates.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidfailure(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.voidsuccess(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)Called after the listener exits normally.
-
-
-
Constructor Detail
-
CompositeRecordInterceptor
@SafeVarargs public CompositeRecordInterceptor(RecordInterceptor<K,V>... delegates)
Construct an instance with the provided delegates.- Parameters:
delegates- the delegates.
-
-
Method Detail
-
intercept
public org.apache.kafka.clients.consumer.ConsumerRecord<K,V> intercept(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)
Description copied from interface:RecordInterceptorPerform some action on the record or return a different one. If null is returned the record will be skipped. Invoked before the listener.- Specified by:
interceptin interfaceRecordInterceptor<K,V>- Parameters:
record- the record.- Returns:
- the record or null.
-
success
public void success(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)
Description copied from interface:RecordInterceptorCalled after the listener exits normally.- Specified by:
successin interfaceRecordInterceptor<K,V>- Parameters:
record- the record.
-
failure
public void failure(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record, java.lang.Exception exception)
Description copied from interface:RecordInterceptorCalled after the listener throws an exception.- Specified by:
failurein interfaceRecordInterceptor<K,V>- Parameters:
record- the record.exception- the exception.
-
-