我为一个批处理侦听器编写了一个自定义的错误处理程序,它应该在接收到的记录之后进行查找,并将它们发送到dlq。我试了很多,但没有让它工作。我当前的实现将在一个无限循环中挂起,一遍又一遍地接收记录。下面是错误处理程序代码: @Service("consumerAwareListenerErrorHandlerImpl")
public class ConsumerAwareListenerErrorHandlerImpl
我需要识别数据库连接失败异常与其他异常,并在我的kafka侦听器错误处理程序中进行相应的处理。由于Spring Data JPA中的所有内容都被转换为DataAcccessException,我只是想知道当应用程序运行时发生连接故障时会抛出什么异常。工作环境: Spring boot 2.x、Spring data jpa、spring-kafka、Java 8