Class AbstractFilteringMessageListener<K,V,T>
- java.lang.Object
-
- org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter<T>
-
- org.springframework.kafka.listener.adapter.AbstractFilteringMessageListener<K,V,T>
-
- Type Parameters:
K
- the key type.V
- the value type.T
- the delegate type.
- All Implemented Interfaces:
ConsumerSeekAware
,DelegatingMessageListener<T>
- Direct Known Subclasses:
FilteringBatchMessageListenerAdapter
,FilteringMessageListenerAdapter
public abstract class AbstractFilteringMessageListener<K,V,T> extends AbstractDelegatingMessageListenerAdapter<T>
An abstract message listener adapter that implements record filter logic via aRecordFilterStrategy
.- Author:
- Gary Russell
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.springframework.kafka.listener.ConsumerSeekAware
ConsumerSeekAware.ConsumerSeekCallback
-
-
Field Summary
-
Fields inherited from class org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter
delegate, delegateType, logger
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
AbstractFilteringMessageListener(T delegate, RecordFilterStrategy<K,V> recordFilterStrategy)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected boolean
filter(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> consumerRecord)
protected RecordFilterStrategy<K,V>
getRecordFilterStrategy()
-
Methods inherited from class org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter
getDelegate, onIdleContainer, onPartitionsAssigned, onPartitionsRevoked, registerSeekCallback
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.springframework.kafka.listener.ConsumerSeekAware
unregisterSeekCallback
-
-
-
-
Constructor Detail
-
AbstractFilteringMessageListener
protected AbstractFilteringMessageListener(T delegate, RecordFilterStrategy<K,V> recordFilterStrategy)
-
-
Method Detail
-
getRecordFilterStrategy
protected RecordFilterStrategy<K,V> getRecordFilterStrategy()
-
-