SeekToCurrentBatchErrorHandler 支持死 DLQ
SeekToCurrentBatchErrorHandler support for dead DLQ
目前我们使用 SeekToCurrentErrorHandler 并使用 DeadLetterPublishingRecoverer 将失败的记录发布到死信主题。我们现在更改代码以消费批量记录,这需要实现 BatchErrorHandler,但 SeekToBatchErrorHandler 不支持 DeadLetterPublishingRecoverer 将记录发布到死信主题。谁能指导如何实现这一目标?
无法支持此功能,因为框架不知道批处理中的哪条记录失败;它所能做的就是将整批发送到 DLT,这并不是(大多数)人们想要的。
批处理中的错误必须在侦听器本身内处理。
目前我们使用 SeekToCurrentErrorHandler 并使用 DeadLetterPublishingRecoverer 将失败的记录发布到死信主题。我们现在更改代码以消费批量记录,这需要实现 BatchErrorHandler,但 SeekToBatchErrorHandler 不支持 DeadLetterPublishingRecoverer 将记录发布到死信主题。谁能指导如何实现这一目标?
无法支持此功能,因为框架不知道批处理中的哪条记录失败;它所能做的就是将整批发送到 DLT,这并不是(大多数)人们想要的。
批处理中的错误必须在侦听器本身内处理。