スループットが遅すぎる

アプリケーションのデータソースが Kinesis ストリームの場合、ストリームの millisbehindLatest メトリクスは継続的に増加します。

アプリケーションのデータソースが Amazon MSKクラスターの場合、クラスターのコンシューマーラグメトリクスは継続的に増加します。詳細については、「Amazon MSKデベロッパーガイド」の「コンシューマーラグのモニタリング」を参照してください。

アプリケーションのデータソースが別のサービスまたはソースである場合は、入手可能なコンシューマーラグのメトリクスまたはデータを確認してください。

スループットラグが急上昇し、その後次第に減少する場合は、アプリケーションが再起動しているかどうかを確認してください。アプリケーションは再起動中に入力の処理を停止するため、遅延が急増します。アプリケーションの障害については、「アプリケーションを再起動中」を参照してください。

スループットの遅延がずっと続く場合は、アプリケーションのパフォーマンスが最適化されているかどうかを確認してください。アプリケーションのパフォーマンスを最適化する方法については、 パフォーマンス問題のトラブルシューティング を参照してください。

スループットラグが急上昇しているのではなく継続的に増加していて、アプリケーションのパフォーマンスが最適化されている場合は、アプリケーションリソースを増やす必要があります。アプリケーションリソースを増やす方法については、 Managed Service for Apache Flink でアプリケーションスケーリングを実装する を参照してください。

アプリケーションが別のリージョンの Kafka クラスターから読み取りを行ったり、コンシューマーラグが大きいにもかかわらず FlinkKafkaConsumer または KafkaSource がほとんどアイドル状態 (高い idleTimeMsPerSecond または低い CPUUtilization) になっている場合は、2097152 など receive.buffer.byte の値を増やすことができます。詳細については、「カスタムMSK設定」の「高レイテンシー環境」セクションを参照してください。