我怎样才能使一堆自定义异常成为不可重试的异常?
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 注释创建一个消费者,我我正在使用消费者的所有默认设置。
现在我的问题
- 如何使一堆自定义异常成为不可重试异常(例如 DeserializationException)?
将异常分类为可重试或不可重试的功能已添加到版本 2.3(引导 2.2)中的 SeekToCurrentErrorHandler
。
https://github.com/spring-projects/spring-kafka/issues/983
由 https://github.com/spring-projects/spring-kafka/issues/1260
改进
默认情况下,反序列化异常被归类为不可重试。
我正在使用 spring boot 2.1.7.RELEASE 和 spring-kafka 2.2.8.RELEASE.And 我正在使用 @KafkaListener 注释创建一个消费者,我我正在使用消费者的所有默认设置。
现在我的问题
- 如何使一堆自定义异常成为不可重试异常(例如 DeserializationException)?
将异常分类为可重试或不可重试的功能已添加到版本 2.3(引导 2.2)中的 SeekToCurrentErrorHandler
。
https://github.com/spring-projects/spring-kafka/issues/983
由 https://github.com/spring-projects/spring-kafka/issues/1260
改进默认情况下,反序列化异常被归类为不可重试。