私は、リアクティブなアプローチでSpring Cloud機能を備えたSpring Cloud Streamを使用しています。私のバインダーはRabbitMQです。定義上、 maxAttemptsプロパティは、メッセージを処理できる回数です (それは私が解釈するものです) /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デフォルトですが、すでに設定しようとしました。
メッセージを一度だけ処理する方法についての手がかりはありますか?
ありがとう。