症状
Message Queue for Apache Kafka コンソールにログインします。メッセージクエリ ページで、クエリモード を 時点によるクエリ に設定し、時間 を指定します。クエリを実行すると、メッセージ作成時間 が指定した時刻と大幅に異なるメッセージ、または メッセージ作成時間 の値が空のメッセージが返されます。
原因
-
指定した時刻がパーティション内のメッセージのタイムスタンプの範囲外 (最も古いタイムスタンプより前、または最も新しいタイムスタンプより後) である場合、コンシューマオフセットは最大オフセットにリセットされます。その結果、メッセージ作成時間 列には、この最大オフセットにあるメッセージのタイムスタンプが表示されます。
-
メッセージ作成時間 列の値が null の場合は、メッセージが古いバージョンのクライアントから送信されたことを示しています。このクライアントのメッセージフォーマットには、タイムスタンプ属性が含まれていません。
ソリューション
メッセージ作成時間 の値が null の場合は、クライアントをバージョン 2.2.0 以降 (バージョン 2.4.0 を推奨) にアップグレードしてください。