在 Spring-Kafka 中,我们是否有在每次重试尝试时调用的任何侦听器或拦截器?
In Spring-Kafka, do we have any listener or interceptor that gets invoked on each retry attempt?
我正在使用 spring boot 2.1.7.RELEASE 和 spring-kafka 2.2.8.RELEASE.And 我正在使用 @KafkaListener 注释创建一个消费者,我我正在使用消费者的所有默认设置。
现在我的问题是,
1. 在 Spring-Kafka 中,我们是否有在每次重试尝试时调用的任何侦听器或拦截器?
如果您使用自定义 RetryTemplate
配置容器工厂,您可以将 RetryListener
添加到模板。
我正在使用 spring boot 2.1.7.RELEASE 和 spring-kafka 2.2.8.RELEASE.And 我正在使用 @KafkaListener 注释创建一个消费者,我我正在使用消费者的所有默认设置。
现在我的问题是, 1. 在 Spring-Kafka 中,我们是否有在每次重试尝试时调用的任何侦听器或拦截器?
如果您使用自定义 RetryTemplate
配置容器工厂,您可以将 RetryListener
添加到模板。