インターフェースの使用
org.springframework.kafka.listener.adapter.RecordFilterStrategy
RecordFilterStrategy を使用するパッケージ
パッケージ
説明
kafka 構成のパッケージ
リスナーを適応させるためのクラスを提供します。
org.springframework.kafka.config 内の RecordFilterStrategy 使用
修飾子と型メソッド説明protected RecordFilterStrategy<? super K,
? super V> AbstractKafkaListenerEndpoint.getRecordFilterStrategy()
型 RecordFilterStrategy のパラメーターを持つ org.springframework.kafka.config のメソッド修飾子と型メソッド説明void
AbstractKafkaListenerContainerFactory.setRecordFilterStrategy
(RecordFilterStrategy<? super K, ? super V> recordFilterStrategy) レコードフィルター戦略を設定します。void
AbstractKafkaListenerEndpoint.setRecordFilterStrategy
(RecordFilterStrategy<? super K, ? super V> recordFilterStrategy) RecordFilterStrategy
実装を設定します。org.springframework.kafka.listener.adapter 内の RecordFilterStrategy 使用
修飾子と型メソッド説明protected RecordFilterStrategy<K,
V> AbstractFilteringMessageListener.getRecordFilterStrategy()
型 RecordFilterStrategy のパラメーターを持つ org.springframework.kafka.listener.adapter のコンストラクター修飾子コンストラクター説明protected
AbstractFilteringMessageListener
(T delegate, RecordFilterStrategy<K, V> recordFilterStrategy) FilteringBatchMessageListenerAdapter
(BatchMessageListener<K, V> delegate, RecordFilterStrategy<K, V> recordFilterStrategy) 提供された戦略とデリゲートリスナーを使用してインスタンスを作成します。FilteringBatchMessageListenerAdapter
(BatchMessageListener<K, V> delegate, RecordFilterStrategy<K, V> recordFilterStrategy, boolean ackDiscarded) 提供された戦略とデリゲートリスナーを使用してインスタンスを作成します。FilteringMessageListenerAdapter
(MessageListener<K, V> delegate, RecordFilterStrategy<K, V> recordFilterStrategy) 提供された戦略とデリゲートリスナーを使用してインスタンスを作成します。FilteringMessageListenerAdapter
(MessageListener<K, V> delegate, RecordFilterStrategy<K, V> recordFilterStrategy, boolean ackDiscarded) 提供された戦略とデリゲートリスナーを使用してインスタンスを作成します。