メッセージ消費で例外が発生した場合、ApsaraMQ for RocketMQ コンソールで指定したコンシューマーグループ (Group) のステータスを表示できます。これには、コンシューマーのオンラインステータス、サブスクリプションの一貫性、メッセージの蓄積メトリック、コンシューマークライアント情報などが含まれ、例外の原因を迅速に特定するのに役立ちます。
ユースケース
オンラインステータス、サブスクリプション、消費 TPS、メッセージの蓄積、スレッドスタック情報などのコンシューマーのステータス情報は、多くの場合、次のシナリオでのトラブルシューティングに使用されます。
|
シナリオ |
症状 |
推奨されるアクション |
|
サブスクリプションの不整合 |
グループ詳細 ページで、コンシューマーグループの サブスクリプション関係 ステータスに[サブスクリプション関係が一致していません。できるだけ早く処理してください!]と表示されます。 |
サブスクリプションの不整合をご参照ください。 |
|
メッセージの蓄積 |
グループ詳細 ページで、処理中のメッセージ数、レディネスメッセージの数、キュータイム の値が想定よりも高くなります。 |
メッセージ蓄積の対処方法をご参照ください。 |
コンシューマーグループの情報
操作手順
ApsaraMQ for RocketMQコンソールにログインします。 左側のナビゲーションウィンドウで、インスタンス数 をクリックします。
上部のナビゲーションバーで、中国 (杭州) などのリージョンを選択します。 [インスタンス] ページで、管理するインスタンスの名前をクリックします。
-
左側のナビゲーションペインで、グループ管理 をクリックします。次に、グループリストで対象のグループをクリックします。
結果
次の表では、このページのフィールドについて説明します。
|
フィールド |
説明 |
|
[消費者ステータス] |
|
|
[消費モード] |
コンシューマーがメッセージをサブスクライブする際のモードです。 ApsaraMQ for RocketMQ は、クラスター消費モードとブロードキャスト消費モードをサポートしています。デフォルトはクラスター消費モードです。消費モードはコンシューマークライアントで変更できます。 詳細については、「クラスター消費とブロードキャスト消費」をご参照ください。 |
|
[リアルタイム消費速度] |
コンシューマーグループ内のすべてのコンシューマーインスタンスの合計消費 TPS です。単位：メッセージ/秒。 |
|
処理中のメッセージ数 |
コンシューマークライアントが処理中で、まだ消費結果を返していないメッセージです。 |
|
レディネスメッセージの数 |
ApsaraMQ for RocketMQ サーバー上にあり、消費可能なメッセージです。 |
|
キュータイム |
最も古い準備完了メッセージが消費可能になってからの経過時間です。 この値は、コンシューマーによるメッセージ取得がタイムリーであるかどうかを示します。 |
|
サブスクリプション関係 |
コンシューマーグループ内のコンシューマーインスタンスのサブスクリプションに一貫性があるかどうかを示します。また、各コンシューマークライアントがサブスクライブしているタグも表示します。 サブスクリプションの一貫性の詳細については、「サブスクリプションの一貫性」をご参照ください。 ApsaraMQ for RocketMQ では、オンラインクライアントのサブスクリプションのみ表示できます。 |
|
クライアント接続情報 |
現在オンラインのコンシューマークライアントに関する情報 (IP アドレス、クライアントバージョン、スタック情報など) を表示します。 |
メッセージの蓄積
操作手順
グループ管理 ページで、ダッシュボード をクリックします。
ダッシュボードを使用して、特定のインスタンスのすべてのメトリックを表示することもできます。詳細については、「ダッシュボード」をご参照ください。
結果
コンシューマーグループのダッシュボードには、現在のグループの消費状況に関連するメトリックが表示されます。これには、指定したトピックにおけるグループのメッセージ蓄積と消費レートや、そのトピックのメッセージ蓄積と生成/消費レートの変化を示すトレンドチャートなどが含まれます。
消費例外が発生した場合は、次の手順に従って問題をトラブルシューティングできます。
-
消費状況のメトリックで、消費ラグが最も大きいトピック (メッセージ蓄積量が最も多いトピック) を特定します。
-
チャートの上にあるフィルター条件で、前の手順で特定した問題のあるトピックを選択します。
-
メッセージの蓄積と生成/消費レートのトレンドチャートでそのトピックの傾向を確認し、例外が発生した時間範囲を絞り込みます。
-
その時間範囲内にバックエンド操作が実行されたか、あるいはネットワーク例外が発生したかを確認します。
関連ドキュメント
コンソールに加えて、API を使用してコンシューマーグループの消費ステータスとメッセージの蓄積を照会することもできます。