K - the key type.V - the value type.T - the delegate type.public abstract class AbstractFilteringMessageListener<K,V,T> extends AbstractDelegatingMessageListenerAdapter<T>
RecordFilterStrategy.ConsumerSeekAware.ConsumerSeekCallbackdelegate, 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, registerSeekCallbackclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitunregisterSeekCallback