K - the key type.V - the value type.public abstract class AbstractFilteringMessageListener<K,V>
extends java.lang.Object
RecordFilterStrategy.| Modifier | Constructor and Description |
|---|---|
protected |
AbstractFilteringMessageListener(RecordFilterStrategy<K,V> recordFilterStrategy) |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
filter(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> consumerRecord) |
protected AbstractFilteringMessageListener(RecordFilterStrategy<K,V> recordFilterStrategy)