トピックパーティション

イベントは、トピック内の 1 つ以上のパーティションに格納されます。トピックをパーティションに分割すると、 Hermes Kafka クラスター内の複数のブローカーに処理負荷を分散させることができます。各ブローカーは、同じトピックの異なるパーティションからのメッセージを処理できるため、単一のブローカーが 1 つのトピックのすべてのメッセージの処理を担当しないようにします。このディストリビューションにより、スケーラビリティとフォールトトレランスが向上します。

パーティション内のイベントは不変です。1 つのイベントが同じパーティション内の別のイベントを上書きすることはできません。同じイベントがパーティションに複数回送信されると、パーティション内のイベントのリストに追加されます。

パーティション内のメッセージの追跡

パーティション情報を表示することで、 Hermes Kafka クラスター内のメッセージを追跡できます。

• トピックへのメッセージを生成するときに終了オフセット値が変更されるかどうかを確認することで、メッセージが Hermes Kafka クラスターに到達しているかどうかを判断します。
• メッセージが期限切れになると増加する開始オフセット値をメモして、メッセージが期限切れかどうかを判断します。トピックにメッセージを送信しても、開始オフセットが予想よりも大きい場合は、一部のメッセージが既に期限切れになっています。Hermes Kafka クラスター内のメッセージは 36 時間経過すると期限切れになります。

コンシューマーの進捗状況の追跡

コンシューマー情報を表示することで、各コンシューマーのメッセージ処理の進捗状況を追跡できます。

• 各コンシューマーのグループ ID とコンシューマー ID を含む、トピック内の各パーティションのコンシューマーを表示します。
• [現在のオフセット] 列を表示して、コンシューマーが処理しているメッセージを特定します。
• [遅延] 列を確認して、コンシューマーが遅延しているかどうかを判断します。遅延は、現在のオフセットと終了オフセットの差であり、残っているメッセージの数を示します。

メッセージの詳細の検査

トピックインスペクターを使用して、メッセージの消費に関する問題を検出できます。たとえば、生成したメッセージが Hermes Kafka クラスターから消費されない場合は、トピックを検査することでペイロードとメッセージキーを検証できます。完全なペイロードをダウンロードして、ローカルマシンにファイルとして保存することもできます。

システムプロパティを追加することで、メッセージを UTF8 文字列ではなく Base 64 エンコードのバイナリデータとして表示できます。「Hermes メッセージングサービス のシステムプロパティ」を参照してください。