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 TypeMethodDescriptionvoidAbstractKafkaListenerContainerFactory.setRecordFilterStrategy(RecordFilterStrategy<? super K, ? super V> recordFilterStrategy) Set the record filter strategy.voidAbstractKafkaListenerEndpoint.setRecordFilterStrategy(RecordFilterStrategy<? super K, ? super V> recordFilterStrategy) Set aRecordFilterStrategyimplementation. -
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 RecordFilterStrategyModifierConstructorDescriptionprotectedAbstractFilteringMessageListener(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.