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 TypeMethodDescriptionvoidFailedBatchProcessor.setRetryListeners(RetryListener... listeners) voidFailedRecordProcessor.setRetryListeners(RetryListener... listeners) Set one or moreRetryListenerto receive notifications of retries and recovery.Method parameters in org.springframework.kafka.listener with type arguments of type RetryListenerModifier and TypeMethodDescriptionstatic voidErrorHandlingUtils.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) 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.