我已经配置了一个errorHandler,它将记录发送到DLT public DeadLetterPublishingRecoverer recoverer(KafkaTemplate<String, List<T>> template) { }new SeekToCurrentErrorHandler(recoverer, new F
我尝试将Spring Kafka与一批消息一起使用,每次当我的onMessage()方法抛出MyKafkaRetryException时,就会开始一个无限的重新处理循环,但我希望在重试结束后,这批消息会被移到DLT。(如果我抛出任何其他异常,则会立即将消息移动到DLT。)我刚刚用我自己的异常分类配置了一个RecoveringBatchErrorHandler。所以我不知道这里出了什么问题。factory.setBatchErrorHandler(recoveringBatchErrorHandler);
return fac
如果重试已用尽,则将带有自定义名称(main-topic-name.deadLetter)的死信发送到邮件中。Observations
如果我使用DeadLetterPublishingRecoverer而不重试相关的属性配置,则可以使用硬编码的FixedBackOff (return new DefaultErrorHandler通过只使用DeadLetterPublishingRecoverer,我不会得到一个单独的重试主题。通过使用<