問題タブ [spring-cloud-aws]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
amazon-web-services - Spring Cloud aws でのポーリング スレッドの動作
ポーリング スレッドの動作について、少し疑問があります。
ポーリングごとに受信する maxNumberOfMessages が 10 であるシナリオを考えてみましょう。また、DEFAULT_WAIT_TIME = 20 秒を使用しています。以下で説明するさまざまなシナリオでどのように動作するかを知りたいです。
- キューに 5 ～ 6 個のメッセージがある場合。じゃあ何個返せる？また、ポーリング スレッドはさらにメッセージを取得するまでしばらく待機しますか?
- キューにメッセージがない場合、1 つのメッセージを取得するまで待機しますか、それともそれ以上待機しますか?
- キューに 10 を超えるメッセージがある場合、どのように動作しますか?
spring-cloud-stream - Spring Kinesis Binder がヒープ領域を急速に満たし、GC フラッシュが頻繁に発生し、メッセージ処理が遅くなる
私のアプリケーションは 1 つのストリームから消費し、3 つのストリームにメッセージをプッシュしています
バインダー：
構成:
各レコードでストリーミングするためにプッシュするデータは、約 800kb です。非常に頻繁な GC フラッシュを引き起こしている AbstractAwsMessageHandler/AmazonKinesisAsyncClient により多くのデータがあることがわかります。
Binder の 1.0.0.RELEASE バージョンを使用しています
助けてください。
spring-cloud-stream - dynamo db テーブルの Kinesis Binder のデフォルトの読み取り容量と書き込み容量
Spring Aws Kinesis Binder のドキュメントによると、readCapacity と writeCapacity のデフォルト値は 1 です。
readCapacity DynamoDb テーブルの読み取り容量。Kinesis プロビジョニング済みスループットを参照してください
デフォルト: 1
writeCapacity DynamoDb テーブルの書き込み容量。Kinesis プロビジョニング済みスループットを参照してください。 デフォルト: 1
Kinesis Client コードから、デフォルト値が 10 であることがわかります。
Spring Kinesis Binder にカスタマイズはありますか。
編集
読み取りおよび書き込み容量が 40 の locks テーブルがあります。
このようにバインダーを構成しました
これらの構成で実行されている 3 つのコンテナーがあります。
customLocks テーブルに対して ProvisionedThroughputExceededException が表示されます。
バインダーが dynamo db ロック テーブルをオーバーロードしようとしているかどうかは不明です。