問題タブ [spring-cloud-function]

私は、リアクティブなアプローチで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デフォルトですが、すでに設定しようとしました。

メッセージを一度だけ処理する方法についての手がかりはありますか?

ありがとう。

こんにちは、わかりません。「 spring-cloud-function」または「 」のドキュメントに記載されていませんspring-cloud-stream。Uppercase" " と " "の 2 つの関数があるとしreverseます。" " に出力する " " 関数へのuppercase-source入力" " というソース キューがあるとします。そして、"uppercase-output" は、" " に出力する " " 関数のソースです。Uppercaseuppercase-outputreversereverse-output

次の方法で関数合成を実行すると:

結果の関数は「大文字」と「逆」の間で値渡しを使用しますか、それとも結果の関数は「大文字出力」と言う間にキュー/トピックを使用しますか?

https://spring.io/blog/2018/10/22/functional-bean-registrations-in-spring-cloud-functionに記載されている機能 Bean 登録を使用して、AWS Lambda にデプロイしようとしました。https://github.com/mydeveloperplanet/MySpringCloudFunctionPlanet/tree/feature/aws-funtion-bean-definitionのコードを参照してください。

ただし、アプリケーションを関数 Bean スタイルに変換すると、次のエラーが発生します。

コードは次のとおりです (GitHub https://github.com/mydeveloperplanet/MySpringCloudFunctionPlanet/tree/masterで入手できます)。

ここで何が欠けていますか？