Uses of Interface
org.springframework.kafka.listener.adapter.RecordFilterStrategy
Package
Description
Package for kafka configuration
Provides classes for adapting listeners.
-
Uses of RecordFilterStrategy in org.springframework.kafka.config
Modifier and TypeMethodDescriptionprotected RecordFilterStrategy<? super K,
? super V> AbstractKafkaListenerEndpoint.getRecordFilterStrategy()
Modifier 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
Modifier and TypeMethodDescriptionprotected RecordFilterStrategy<K,
V> AbstractFilteringMessageListener.getRecordFilterStrategy()
ModifierConstructorDescriptionprotected
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.