spring kafka批处理错误处理程序实现-需要了解一些示例
spring kafka batch error handler implementation- need to know some examples
只是想知道如何使用批处理错误处理程序。想看一些例子。
我的需求是当batch consumer消费列表或者记录的时候遇到毒丸（无效记录-格式不一样），直接跳过记录即可。
谢谢
在最新版本（2.8）中，使用DefaultErrorHandlerhttps://docs.spring.io/spring-kafka/docs/current/reference/html/#default-eh
在以前的版本中，使用 RecoveringBatchErrorHandler https://docs.spring.io/spring-kafka/docs/2.7.9/reference/html/#recovering-batch-eh
在任何一种情况下，您都会抛出一个 BatchListenerFailedException，其中包含有关批次中哪条记录失败的信息；错误处理程序将提交该记录之前的记录的偏移量，并重试（或跳过）失败的记录。
您可以配置错误处理程序来指示哪些异常是可重试的，哪些不是。
只是想知道如何使用批处理错误处理程序。想看一些例子。
我的需求是当batch consumer消费列表或者记录的时候遇到毒丸（无效记录-格式不一样），直接跳过记录即可。
谢谢
在最新版本（2.8）中，使用DefaultErrorHandlerhttps://docs.spring.io/spring-kafka/docs/current/reference/html/#default-eh
在以前的版本中，使用 RecoveringBatchErrorHandler https://docs.spring.io/spring-kafka/docs/2.7.9/reference/html/#recovering-batch-eh
在任何一种情况下，您都会抛出一个 BatchListenerFailedException，其中包含有关批次中哪条记录失败的信息；错误处理程序将提交该记录之前的记录的偏移量，并重试（或跳过）失败的记录。
您可以配置错误处理程序来指示哪些异常是可重试的，哪些不是。