Package io.micronaut.configuration.kafka.retry
package io.micronaut.configuration.kafka.retry
-
ClassDescriptionInterface that can be implemented to provide conditional retry behaviour for a
KafkaConsumer
when aConsumerRecord
fails to be processed and the error strategy is set to conditionally retry.The conditional retry behaviours.The default ConditionalRetryBehaviourHandler used when aKafkaConsumer
fails to process aConsumerRecord
and the error strategy is set to conditionally retry.