Uses of Interface
org.springframework.kafka.listener.RetryListener
Packages that use RetryListener
-
Uses of RetryListener in org.springframework.kafka.listener
Methods in org.springframework.kafka.listener that return types with arguments of type RetryListenerModifier and TypeMethodDescriptionprotected List<RetryListener>
FailedRecordProcessor.getRetryListeners()
Methods in org.springframework.kafka.listener with parameters of type RetryListenerModifier and TypeMethodDescriptionvoid
FailedBatchProcessor.setRetryListeners
(RetryListener... listeners) void
FailedRecordProcessor.setRetryListeners
(RetryListener... listeners) Set one or moreRetryListener
to receive notifications of retries and recovery.Method parameters in org.springframework.kafka.listener with type arguments of type RetryListenerModifier and TypeMethodDescriptionstatic void
ErrorHandlingUtils.retryBatch
(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> records, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, Runnable invokeListener, BackOff backOff, CommonErrorHandler seeker, BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecords<?, ?>, Exception> recoverer, LogAccessor logger, KafkaException.Level logLevel, List<RetryListener> retryListeners, org.springframework.classify.BinaryExceptionClassifier classifier, boolean reClassifyOnExceptionChange) Retry a complete batch by pausing the consumer and then, in a loop, poll the consumer, wait for the next back off, then call the listener.