Uses of Interface
org.springframework.kafka.listener.RecoveryStrategy
Packages that use RecoveryStrategy
-
Uses of RecoveryStrategy in org.springframework.kafka.listener
Methods in org.springframework.kafka.listener with parameters of type RecoveryStrategyModifier and TypeMethodDescriptionstatic boolean
SeekUtils.doSeeks
(List<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> records, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, Exception exception, boolean recoverable, RecoveryStrategy recovery, MessageListenerContainer container, LogAccessor logger) Seek records to earliest position, optionally skipping the first.static void
SeekUtils.seekOrRecover
(Exception thrownException, List<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> records, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, boolean commitRecovered, RecoveryStrategy recovery, LogAccessor logger, KafkaException.Level level) Seek the remaining records, optionally recovering the first.