具有不同重试尝试的 Kafka 侦听器

Kafka listeners with different retry attempts

我有三个 spring @KafkaListeners,都来自 same 主题,但我需要对每个听众进行不同的重试尝试我猜是因为有不同的 RetryPolicy。

我现在使用的是 2.7.11 版本;我是否也应该定义三个不同的侦听器容器工厂,或者有一种方法可以在同一个侦听器容器工厂上处理它们?

RetryTemplate 容器工厂中的 RetryTemplate 现已弃用,因为错误处理程序支持退避和异常分类。

https://github.com/spring-projects/spring-kafka/issues/1886

您可以将容器定制器添加到工厂并为每个容器设置不同的错误处理程序(具有不同的回退)。