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.
Author:
Gary Russell
  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    filter(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> consumerRecord)
    Return true if the record should be discarded.
    default List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>
    filterBatch(List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> records)
    Filter an entire batch of records; to filter all records, return an empty list, not null.
  • Method Details

    • filter

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

      default List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> filterBatch(List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> records)
      Filter an entire batch of records; to filter all records, return an empty list, not null.
      Parameters:
      records - the records.
      Returns:
      the filtered records.
      Since:
      2.8