34.5. メッセージヘッダー
34.5.1. consumer ヘッダー リンクのコピーリンクがクリップボードにコピーされました!
次のヘッダーは、Kafka からのメッセージを使用するときに使用できます。
ヘッダー定数 | ヘッダーの値 | タイプ | 説明 |
---|---|---|---|
|
|
| メッセージの発信元のトピック |
|
|
| メッセージが格納されたパーティション |
|
|
| メッセージのオフセット |
|
|
| メッセージのキー (設定されている場合) |
|
|
| レコードのヘッダー |
|
|
|
コミット前の最後のレコードかどうか ( |
|
|
|
現在のポーリングリクエスト内の最後のレコードを示します ( |
|
|
| Kafka consumer を使用する場合に手動オフセットコミットを強制するために使用できます。 |
34.5.2. producer ヘッダー リンクのコピーリンクがクリップボードにコピーされました!
メッセージを Kafka に送信する前に、次のヘッダーを設定できます。
ヘッダー定数 | ヘッダーの値 | タイプ | 説明 |
---|---|---|---|
|
|
| 必須 すべての関連メッセージが同じパーティションに入るようにするためのメッセージのキー |
|
|
| メッセージの送信先のトピック (オーバーライドおよび優先)、およびヘッダーは保持されません。 |
|
|
| ProducerRecord には、関連付けられたタイムスタンプもあります。ユーザーがタイムスタンプを提供した場合、producer は提供されたタイムスタンプをレコードにスタンプし、ヘッダーは保持されません。 |
|
|
| パーティションを明示的に指定する |
動的トピックにメッセージを送信する場合は、KafkaConstants.OVERRIDE_TOPIC
を、producer で削除されるため、メッセージに沿って送信されないワンタイムヘッダーとして使用します。
メッセージが Kafka に送信された後、次のヘッダーを使用できます
ヘッダー定数 | ヘッダーの値 | タイプ | 説明 |
---|---|---|---|
|
|
|
メタデータ ( |