K - the key type.V - the value type.public interface RecordFilterStrategy<K,V>
| Modifier and Type | Method and Description |
|---|---|
boolean |
filter(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> consumerRecord)
Return true if the record should be discarded.
|