Package io.micronaut.configuration.kafka.retry

Interface ConditionalRetryBehaviourHandler

All Known Implementing Classes:

DefaultConditionalRetryBehaviourHandler

public interface ConditionalRetryBehaviourHandler

Interface that can be implemented to provide conditional retry behaviour for a KafkaConsumer when a ConsumerRecord fails to be processed and the error strategy is set to conditionally retry.

Since:

5.4.0

Author:

Ryan Evans

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	ConditionalRetryBehaviourHandler.ConditionalRetryBehaviour	The conditional retry behaviours.

Method Summary

Modifier and Type	Method	Description
ConditionalRetryBehaviourHandler.ConditionalRetryBehaviour	conditionalRetryBehaviour(KafkaListenerException exception)	Returns the seek behaviour for the given exception.

Method Details

conditionalRetryBehaviour

ConditionalRetryBehaviourHandler.ConditionalRetryBehaviour conditionalRetryBehaviour(KafkaListenerException exception)

Returns the seek behaviour for the given exception.

Parameters:

exception - The exception that occurred when attempting to process a record

Returns:

The conditional retry behaviour