K - the key type.V - the value type.T - the delegate type.public abstract class AbstractFilteringMessageListener<K,V,T> extends AbstractMessageListenerAdapter<K,V,T>
RecordFilterStrategy.ConsumerSeekAware.ConsumerSeekCallbackdelegate, 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) |
onIdleContainer, onPartitionsAssigned, registerSeekCallback