我怎样才能使一堆自定义异常成为不可重试的异常?

How can I a make a bunch of custom exceptions to be a non-retry-able exception?

我正在使用 spring boot 2.1.7.RELEASE 和 spring-kafka 2.2.8.RELEASE.And 我正在使用 @KafkaListener 注释创建一个消费者,我我正在使用消费者的所有默认设置。

现在我的问题

  1. 如何使一堆自定义异常成为不可重试异常(例如 DeserializationException)?

将异常分类为可重试或不可重试的功能已添加到版本 2.3(引导 2.2)中的 SeekToCurrentErrorHandler

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

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

改进

默认情况下,反序列化异常被归类为不可重试。