Example KafkaConsumerConfiguration for FixedBackOff strategy

KafkaConsumerConfiguration.java

@Configuration
public class KafkaConsumerConfiguration {
    
    @Bean
    ConcurrentKafkaListenerContainerFactory<String, String> kafkaBlockingRetryContainerFactory() {
        ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();
        factory.setConsumerFactory(consumerFactory);
        factory.setCommonErrorHandler(new DefaultErrorHandler(
                new DeadLetterPublishingRecoverer(template), new FixedBackOff(5000, 3))
        );
        return factory;
    }
}