Search code examples
spring-kafka

In Spring-Kafka, do we have any listener or interceptor that gets invoked on each retry attempt?


I'm using spring boot 2.1.7.RELEASE and spring-kafka 2.2.8.RELEASE.And I'm using @KafkaListener annotation to create a consumer and I'm using all default settings for the consumer.

Now my question is, 1. In Spring-Kafka, do we have any listener or interceptor that gets invoked on each retry attempt?


Solution

  • If you configure the container factory with a custom RetryTemplate you can add a RetryListener to the template.