K
- the key type.V
- the value type.T
- the delegate type.public abstract class AbstractFilteringMessageListener<K,V,T> extends AbstractDelegatingMessageListenerAdapter<T>
RecordFilterStrategy
.ConsumerSeekAware.ConsumerSeekCallback
delegate, delegateType, logger
Modifier | Constructor and Description |
---|---|
protected |
AbstractFilteringMessageListener(T delegate,
RecordFilterStrategy<K,V> recordFilterStrategy) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
filter(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> consumerRecord) |
getDelegate, onIdleContainer, onPartitionsAssigned, onPartitionsRevoked, registerSeekCallback
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
unregisterSeekCallback