spring - SeekToCurrentBatchErrorHandler 对死 DLQ 的支持

标签 spring spring-kafka

目前我们使用SeekToCurrentErrorHandler并使用DeadLetterPublishingRecoverer将失败的记录发布到死信主题。我们现在正在更改代码以消耗批量记录,这需要实现 BatchErrorHandler,但 SeekToBatchErrorHandler 不支持 DeadLetterPublishingRecoverer 将记录发布到死信主题。谁能指导如何实现这一目标?

最佳答案

无法支持此操作,因为框架不知道批处理中的哪条记录失败;它所能做的就是将整个批处理发送到 DLT,这并不是(大多数)人们真正想要的。

批处理中的错误必须在监听器本身内处理。

关于spring - SeekToCurrentBatchErrorHandler 对死 DLQ 的支持,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/60092423/

相关文章:

java - 使用 SpringJunit4ClassRunner 在属性占位符之前设置系统属性或环境变量

apache-kafka - 将无法反序列化的消息发布到DLT主题

java - kafka @Listener异常处理-无法配置批量重试

java - Spring Kafka-用Producer Listener配置KafkaTemplate和用Listenable Future注册回调的区别

javascript - 如何使用 jquery/javascript、Spring 按 id 删除?

java - 异常: org. hibernate.AnnotationException : No identifier specified for entity: jpa.租户.DataSourceConfig

docker - SSL.keystore.location 在我的 Kubernetes secret 挂载中找不到 JKS 文件

rest - Kafka 消息 VS REST 调用

java - 将多个 dao 注入(inject)到一个服务中

java - Spring:从 Web 应用程序线程子线程(来自 ThreadPool)访问请求( session )作用域 Bean