Uses of Interface
org.springframework.kafka.listener.RecoveryStrategy
-
Uses of RecoveryStrategy in org.springframework.kafka.listener
Modifier and TypeMethodDescriptionprotected RecoveryStrategy
FailedRecordProcessor.getRecoveryStrategy
(List<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> records, Exception thrownException) Return aRecoveryStrategy
to call to determine whether the first record in the list should be skipped.protected RecoveryStrategy
FailedRecordProcessor.getRecoveryStrategy
(List<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> records, org.apache.kafka.clients.consumer.Consumer<?, ?> recoveryConsumer, Exception thrownException) Return aRecoveryStrategy
to call to determine whether the first record in the list should be skipped.Modifier 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.