Hermes Kafka クラスターのトピックの監視
Hermes メッセージングサービス トピックインスペクターを使用して、自分に属する Hermes Kafka クラスターでメッセージ処理を監視し、トピック表示します。
パーティション内のメッセージの追跡
パーティション情報を表示することで、 Hermes Kafka クラスター内のメッセージを追跡できます。
- トピックへのメッセージを生成するときに終了オフセット値が変更されるかどうかを確認することで、メッセージが Hermes Kafka クラスターに到達しているかどうかを判断します。
- メッセージが期限切れになると増加する開始オフセット値をメモして、メッセージが期限切れかどうかを判断します。トピックにメッセージを送信しても、開始オフセットが予想よりも大きい場合は、一部のメッセージが既に期限切れになっています。Hermes Kafka クラスター内のメッセージは 36 時間経過すると期限切れになります。
コンシューマーの進捗状況の追跡
コンシューマー情報を表示することで、各コンシューマーのメッセージ処理の進捗状況を追跡できます。
- 各コンシューマーのグループ ID とコンシューマー ID を含む、トピック内の各パーティションのコンシューマーを表示します。
- [現在のオフセット] 列を表示して、コンシューマーが処理しているメッセージを特定します。
- [遅延] 列を確認して、コンシューマーが遅延しているかどうかを判断します。遅延は、現在のオフセットと終了オフセットの差であり、残っているメッセージの数を示します。
メッセージの詳細の検査
トピックインスペクターを使用して、メッセージの消費に関する問題を検出できます。たとえば、生成したメッセージが Hermes Kafka クラスターから消費されない場合は、トピックを検査することでペイロードとメッセージキーを検証できます。完全なペイロードをダウンロードして、ローカルマシンにファイルとして保存することもできます。
システムプロパティを追加することで、メッセージを UTF8 文字列ではなく Base 64 エンコードのバイナリデータとして表示できます。「Hermes メッセージングサービスのプロパティ」を参照してください。