跳过重试机制，直接转到DLT

Question

我们是我的ErrorHandler日志，并重新抛出任何未由kafkalistener处理的异常，以便重试消息并最终发送到DLT。

有一些失败不应该重试，但应该直接转到DLT，例如json解析错误。

有没有办法跳过某些异常的重试机制？

Answer 1

请参阅Spring重试项目：https://github.com/spring-projects/spring-retry及其ExceptionClassifierRetryPolicy：https://github.com/spring-projects/spring-retry/blob/master/src/main/java/org/springframework/retry/policy/ExceptionClassifierRetryPolicy.java。这就是您可以注入到KafkaListenerContainer的RetryTemplate中的内容。