Uses of Interface
org.springframework.kafka.listener.adapter.RecordFilterStrategy
Packages that use RecordFilterStrategy
Package
Description
Package for kafka configuration
Provides classes for adapting listeners.
-
Uses of RecordFilterStrategy in org.springframework.kafka.config
Methods in org.springframework.kafka.config that return RecordFilterStrategyModifier and TypeMethodDescriptionprotected RecordFilterStrategy<? super K,
? super V> AbstractKafkaListenerEndpoint.getRecordFilterStrategy()
Methods in org.springframework.kafka.config with parameters of type RecordFilterStrategyModifier and TypeMethodDescriptionvoid
AbstractKafkaListenerContainerFactory.setRecordFilterStrategy
(RecordFilterStrategy<? super K, ? super V> recordFilterStrategy) Set the record filter strategy.void
AbstractKafkaListenerEndpoint.setRecordFilterStrategy
(RecordFilterStrategy<? super K, ? super V> recordFilterStrategy) Set aRecordFilterStrategy
implementation. -
Uses of RecordFilterStrategy in org.springframework.kafka.listener.adapter
Methods in org.springframework.kafka.listener.adapter that return RecordFilterStrategyModifier and TypeMethodDescriptionprotected RecordFilterStrategy<K,
V> AbstractFilteringMessageListener.getRecordFilterStrategy()
Constructors in org.springframework.kafka.listener.adapter with parameters of type RecordFilterStrategyModifierConstructorDescriptionprotected
AbstractFilteringMessageListener
(T delegate, RecordFilterStrategy<K, V> recordFilterStrategy) FilteringBatchMessageListenerAdapter
(BatchMessageListener<K, V> delegate, RecordFilterStrategy<K, V> recordFilterStrategy) Create an instance with the supplied strategy and delegate listener.FilteringBatchMessageListenerAdapter
(BatchMessageListener<K, V> delegate, RecordFilterStrategy<K, V> recordFilterStrategy, boolean ackDiscarded) Create an instance with the supplied strategy and delegate listener.FilteringMessageListenerAdapter
(MessageListener<K, V> delegate, RecordFilterStrategy<K, V> recordFilterStrategy) Create an instance with the supplied strategy and delegate listener.FilteringMessageListenerAdapter
(MessageListener<K, V> delegate, RecordFilterStrategy<K, V> recordFilterStrategy, boolean ackDiscarded) Create an instance with the supplied strategy and delegate listener.