インターフェースの使用
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 のメソッド修飾子と型メソッド説明voidAbstractKafkaListenerContainerFactory.setRecordFilterStrategy(RecordFilterStrategy<? super K, ? super V> recordFilterStrategy) レコードフィルター戦略を設定します。voidAbstractKafkaListenerEndpoint.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 のコンストラクター修飾子コンストラクター説明protectedAbstractFilteringMessageListener(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) 提供された戦略とデリゲートリスナーを使用してインスタンスを作成します。