Spring Cloud Stream禁用重试

问题描述

我正在使用具有响应式方法的Spring cloud功能的Spring cloud流。我的活页夹是RabbitMQ。 根据定义，maxAttempts属性是消息可以处理的次数（这就是我的解释） 发件人：https://cloud.spring.io/spring-cloud-static/spring-cloud-stream/3.0.6.RELEASE/reference/html/spring-cloud-stream.html#_consumer_properties

maxAttempts： 如果处理失败，则尝试处理消息的次数（包括第一次）。设置为1可禁用重试。 默认值：3。

问题是我的应用程序使用此（默认）配置始终将消息处理4次。现在，我想禁用重试，因此我将max-attempts = 1设置为始终将邮件处理2次。 我已经尝试设置spring.cloud.stream.rabbit.bindings.input.consumer.requeue-rejected=false，尽管它是默认设置。

关于我如何只处理一次消息的任何线索？

谢谢。

解决方法

Hoxton.SR1很老

我可以看到为什么在这些版本中重试了它；我已将您的示例更新为最新版本，现在仅提供一次...

require(data.table)

some_date <- c("01/02/1979","03/04/1980")
month(as.IDate(some_date,'%d/%m/%Y')) # all data.table functions

我不知道它固定在哪个版本中。