A snippet showing how to configure a RetryTemplate on a KafkaListenerContainer

RetryConfig.groovy

@Bean
public KafkaListenerContainerFactory kafkaListenerContainerFactory(RetryTemplate retryTemplate) {
  def factory = /** configure factory **/
  
  // configure the listener container factory with retry support
  factory.setRetryTemplate(retryTemplate);
  factory.setRecoveryCallback(context -> {
    log.error("RetryPolicy limit has been exceeded! You should really handle this better.");
    return null;
  });

  return factory;
}