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