Interface RecordFilterStrategy<K,​V>

  • Type Parameters:
    K - the key type.
    V - the value type.

    public interface RecordFilterStrategy<K,​V>
    Implementations of this interface can signal that a record about to be delivered to a message listener should be discarded instead of being delivered.
    Gary Russell
    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      boolean filter​(org.apache.kafka.clients.consumer.ConsumerRecord<K,​V> consumerRecord)
      Return true if the record should be discarded.
    • Method Detail

      • filter

        boolean filter​(org.apache.kafka.clients.consumer.ConsumerRecord<K,​V> consumerRecord)
        Return true if the record should be discarded.
        consumerRecord - the record.
        true to discard.