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.
|