springboot集成整合kafka-消费者异常处理器ConsumerAwareListenerErrorHandler
写在前面:各位看到此博客的小伙伴,如有不对的地方请及时通过私信我或者评论此博客的方式指出,以免误人子弟。多谢! 前面生产者在发送消息异常的时候提供了事务机制,确保消费者不会接收到一些错误的或者不需要的消息,那么当消费者对消息消费处理的时候如果发生了异常呢,当然也需要处理一下异常了,一般我们在监听方法中,只是监听topic中的数据并消费,如果再try catch捕获并处理的话,则会显得代码块非常臃肿…