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

クラス AbstractFilteringMessageListener<K,V,T>

java.lang.ObjectSE
org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter<T>
org.springframework.kafka.listener.adapter.AbstractFilteringMessageListener<K,V,T>
型パラメーター:
K - 鍵の型。
V - 値の型。
T - デリゲート型。
実装されたすべてのインターフェース:
ConsumerSeekAware, DelegatingMessageListener<T>
既知の直属サブクラス
FilteringBatchMessageListenerAdapter, FilteringMessageListenerAdapter
public abstract class AbstractFilteringMessageListener<K,V,T> extends AbstractDelegatingMessageListenerAdapter<T>
RecordFilterStrategy を介してレコードフィルターロジックを実装する抽象メッセージリスナーアダプター。
作成者:
Gary Russell

  • コンストラクターの詳細

    • AbstractFilteringMessageListener

      protected AbstractFilteringMessageListener(T delegate, RecordFilterStrategy<K,V> recordFilterStrategy)

  • メソッドの詳細

    • getRecordFilterStrategy

      protected RecordFilterStrategy<K,V> getRecordFilterStrategy()

    • filter

      protected boolean filter(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> consumerRecord)