我只是想知道如何使用批处理错误处理程序。我想看看一些例子。
我的要求是，当批量消费者消费该列表或记录时，如果遇到任何毒丸(无效记录-不同格式(，我们只需要跳过该记录。
感谢
在最新版本(2.8(中，使用DefaultErrorHandlerhttps://docs.spring.io/spring-kafka/docs/current/reference/html/#default-eh
在以前的版本中，使用RecoveringBatchErrorHandlerhttps://docs.spring.io/spring-kafka/docs/2.7.9/reference/html/#recovering-批次eh
在任何一种情况下，都会抛出一个BatchListenerFailedException，其中包含有关批处理中哪个记录失败的信息；错误处理程序将提交该记录之前的记录的偏移量，并重试(或跳过(失败的记录。
您可以配置错误处理程序来指示哪些异常是可重试的，哪些不是。