パッケージ org.springframework.kafka.listener.adapter

インターフェース RecordFilterStrategy<K,V>

型パラメーター:
K - 鍵の型。
V - 値の型。
public interface RecordFilterStrategy<K,V>
このインターフェースの実装は、メッセージリスナーに配信されようとしているレコードを配信する代わりに破棄する必要があることを通知できます。
作成者:
Gary Russell

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    boolean
    filter(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> consumerRecord)
    レコードを破棄する必要がある場合は true を返します。
    default ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>
    filterBatch(ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> records)
    レコードのバッチ全体をフィルタリングします。すべてのレコードをフィルタリングするには、null ではなく空のリストを返します。

  • メソッドの詳細

    • filter

      boolean filter(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> consumerRecord)
      レコードを破棄する必要がある場合は true を返します。
      パラメーター:
      consumerRecord - レコード。
      戻り値:
      破棄するのは本当です。

    • filterBatch

      default ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> filterBatch(ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> records)
      レコードのバッチ全体をフィルタリングします。すべてのレコードをフィルタリングするには、null ではなく空のリストを返します。
      パラメーター:
      records - 記録。
      戻り値:
      フィルタリングされたレコード。
      導入:
      2.8