クラス KafkaHeaders

フィールドの詳細

• PREFIX

  public static final StringSE PREFIX

  Kafka ヘッダーのプレフィックス。

  関連事項:

  • 定数フィールド値

• RECEIVED

  public static final StringSE RECEIVED

  'received' 値を含む Kafka ヘッダーのプレフィックス。

  関連事項:

  • 定数フィールド値

• TOPIC

  public static final StringSE TOPIC

  Kafka にデータを送信するときのトピックを含むヘッダー。

  関連事項:

  • 定数フィールド値

• KEY

  public static final StringSE KEY

  Kafka にデータを送信する際のレコードキーを含むヘッダー。

  導入:

  2.9

  関連事項:

  • 定数フィールド値

• PARTITION

  public static final StringSE PARTITION

  Kafka にデータを送信するときのトピックパーティションを含むヘッダー。

  導入:

  2.0

  関連事項:

  • 定数フィールド値

• OFFSET

  public static final StringSE OFFSET

  パーティションオフセットのヘッダー。

  関連事項:

  • 定数フィールド値

• RAW_DATA

  public static final StringSE RAW_DATA

  Kafka（ConsumerRecord または ConsumerRecords）から受信した生データを含むヘッダー。通常、エラーメッセージを強化するために使用されます。

  関連事項:

  • 定数フィールド値

• RECORD_METADATA

  public static final StringSE RECORD_METADATA

  トピックへの送信が成功した後の RecordMetadata オブジェクトを含むヘッダー。

  関連事項:

  • 定数フィールド値

• ACKNOWLEDGMENT

  public static final StringSE ACKNOWLEDGMENT

  Acknowledgment のヘッダー。

  関連事項:

  • 定数フィールド値

• CONSUMER

  public static final StringSE CONSUMER

  Consumer オブジェクトのヘッダー。

  関連事項:

  • 定数フィールド値

• RECEIVED_TOPIC

  public static final StringSE RECEIVED_TOPIC

  メッセージの受信元のトピックを含むヘッダー。

  関連事項:

  • 定数フィールド値

• RECEIVED_KEY

  public static final StringSE RECEIVED_KEY

  受信したメッセージのレコードキーを含むヘッダー。

  導入:

  2.9

  関連事項:

  • 定数フィールド値

• RECEIVED_PARTITION

  public static final StringSE RECEIVED_PARTITION

  受信したメッセージのトピックパーティションを含むヘッダー。

  導入:

  2.9

  関連事項:

  • 定数フィールド値

• TIMESTAMP_TYPE

  public static final StringSE TIMESTAMP_TYPE

  タイムスタンプの type を保持するためのヘッダー。

  関連事項:

  • 定数フィールド値

• TIMESTAMP

  public static final StringSE TIMESTAMP

  プロデューサーレコードのタイムスタンプを保持するためのヘッダー。

  関連事項:

  • 定数フィールド値

• RECEIVED_TIMESTAMP

  public static final StringSE RECEIVED_TIMESTAMP

  コンシューマーレコードのタイムスタンプを保持するためのヘッダー。

  関連事項:

  • 定数フィールド値

• NATIVE_HEADERS

  public static final StringSE NATIVE_HEADERS

  コンシューマーレコードのネイティブヘッダーを保持するためのヘッダー。ヘッダーマッパーが存在しない場合にのみ提供されます。

  関連事項:

  • 定数フィールド値

• BATCH_CONVERTED_HEADERS

  public static final StringSE BATCH_CONVERTED_HEADERS

  変換されたネイティブ Kafka ヘッダーのマップのリストのヘッダー。バッチリスナーに使用されます。特定のリスト位置のマップは、ペイロードリスト位置のデータに対応します。

  関連事項:

  • 定数フィールド値

• CORRELATION_ID

  public static final StringSE CORRELATION_ID

  リクエスト / 応答を相互に関連付けるための情報を含むヘッダー。型: byte[]。

  導入:

  2.1.3

  関連事項:

  • 定数フィールド値

• REPLY_TOPIC

  public static final StringSE REPLY_TOPIC

  デフォルトの返信トピックを含むヘッダー。型: byte[]。

  導入:

  2.1.3

  関連事項:

  • 定数フィールド値

• REPLY_PARTITION

  public static final StringSE REPLY_PARTITION

  応答を送信するパーティション番号を含むヘッダー。型: byte[] のバイナリ（int）。

  導入:

  2.1.3

  関連事項:

  • 定数フィールド値

• DLT_EXCEPTION_FQCN

  public static final StringSE DLT_EXCEPTION_FQCN

  デッドレタートピックに送信された、公開されたレコードの例外クラス名。

  導入:

  2.2

  関連事項:

  • 定数フィールド値

• DLT_EXCEPTION_CAUSE_FQCN

  public static final StringSE DLT_EXCEPTION_CAUSE_FQCN

  公開されたレコードの例外原因クラス名が、デッドレタートピックに送信されました。

  導入:

  2.8

  関連事項:

  • 定数フィールド値

• DLT_EXCEPTION_STACKTRACE

  public static final StringSE DLT_EXCEPTION_STACKTRACE

  デッドレタートピックに公開されたレコードの例外スタックトレース。

  導入:

  2.2

  関連事項:

  • 定数フィールド値

• DLT_EXCEPTION_MESSAGE

  public static final StringSE DLT_EXCEPTION_MESSAGE

  デッドレタートピックに公開されたレコードの例外メッセージ。

  導入:

  2.2

  関連事項:

  • 定数フィールド値

• DLT_KEY_EXCEPTION_STACKTRACE

  public static final StringSE DLT_KEY_EXCEPTION_STACKTRACE

  キーの逆直列化例外を使用して、配信不能トピックに公開されたレコードの例外スタックトレース。

  導入:

  2.7

  関連事項:

  • 定数フィールド値

• DLT_KEY_EXCEPTION_MESSAGE

  public static final StringSE DLT_KEY_EXCEPTION_MESSAGE

  キーの逆直列化例外を使用して、デッドレタートピックに公開されたレコードの例外メッセージ。

  導入:

  2.7

  関連事項:

  • 定数フィールド値

• DLT_KEY_EXCEPTION_FQCN

  public static final StringSE DLT_KEY_EXCEPTION_FQCN

  公開されたレコードの例外クラス名が、キーの逆直列化例外を伴うデッドレタートピックに送信されました。

  導入:

  2.7

  関連事項:

  • 定数フィールド値

• DLT_ORIGINAL_TOPIC

  public static final StringSE DLT_ORIGINAL_TOPIC

  デッドレタートピックに公開されたレコードの元のトピック。

  導入:

  2.2

  関連事項:

  • 定数フィールド値

• DLT_ORIGINAL_PARTITION

  public static final StringSE DLT_ORIGINAL_PARTITION

  デッドレタートピックに公開されたレコードの元のパーティション。

  導入:

  2.2

  関連事項:

  • 定数フィールド値

• DLT_ORIGINAL_OFFSET

  public static final StringSE DLT_ORIGINAL_OFFSET

  デッドレタートピックに公開されたレコードの元のオフセット。

  導入:

  2.2

  関連事項:

  • 定数フィールド値

• DLT_ORIGINAL_CONSUMER_GROUP

  public static final StringSE DLT_ORIGINAL_CONSUMER_GROUP

  デッドレタートピックに公開されたレコードを消費できなかったコンシューマーグループ。

  導入:

  2.8

  関連事項:

  • 定数フィールド値

• DLT_ORIGINAL_TIMESTAMP

  public static final StringSE DLT_ORIGINAL_TIMESTAMP

  デッドレタートピックに公開されたレコードの元のタイムスタンプ。

  導入:

  2.2

  関連事項:

  • 定数フィールド値

• DLT_ORIGINAL_TIMESTAMP_TYPE

  public static final StringSE DLT_ORIGINAL_TIMESTAMP_TYPE

  デッドレタートピックに公開されたレコードの元のタイムスタンプ型。

  導入:

  2.2

  関連事項:

  • 定数フィールド値

• GROUP_ID

  public static final StringSE GROUP_ID

  受信メッセージの場合、コンテナーの group.id コンシューマープロパティ。

  導入:

  2.3

  関連事項:

  • 定数フィールド値

• DELIVERY_ATTEMPT

  public static final StringSE DELIVERY_ATTEMPT

  受信メッセージの場合、コンテナーの再試行が有効になっていると、配信が試行されます。

  導入:

  2.5

  関連事項:

  • 定数フィールド値

• EXCEPTION_FQCN

  public static final StringSE EXCEPTION_FQCN

  別のトピックに送信された、公開されたレコードの例外クラス名。

  導入:

  2.2

  関連事項:

  • 定数フィールド値

• EXCEPTION_CAUSE_FQCN

  public static final StringSE EXCEPTION_CAUSE_FQCN

  別のトピックに送信された、公開されたレコードの例外クラス名。

  導入:

  2.8

  関連事項:

  • 定数フィールド値

• EXCEPTION_STACKTRACE

  public static final StringSE EXCEPTION_STACKTRACE

  別のトピックに公開されたレコードの例外スタックトレース。

  導入:

  2.2

  関連事項:

  • 定数フィールド値

• EXCEPTION_MESSAGE

  public static final StringSE EXCEPTION_MESSAGE

  別のトピックに公開されたレコードの例外メッセージ。

  導入:

  2.2

  関連事項:

  • 定数フィールド値

• KEY_EXCEPTION_STACKTRACE

  public static final StringSE KEY_EXCEPTION_STACKTRACE

  キー逆直列化例外を使用して別のトピックに公開されたレコードの例外スタックトレース。

  導入:

  2.7

  関連事項:

  • 定数フィールド値

• KEY_EXCEPTION_MESSAGE

  public static final StringSE KEY_EXCEPTION_MESSAGE

  キー逆直列化例外を使用して別のトピックに公開されたレコードの例外メッセージ。

  導入:

  2.7

  関連事項:

  • 定数フィールド値

• KEY_EXCEPTION_FQCN

  public static final StringSE KEY_EXCEPTION_FQCN

  キー逆直列化例外を使用して別のトピックに送信された、公開されたレコードの例外クラス名。

  導入:

  2.7

  関連事項:

  • 定数フィールド値

• ORIGINAL_TOPIC

  public static final StringSE ORIGINAL_TOPIC

  別のトピックに公開されたレコードの元のトピック。

  導入:

  2.2

  関連事項:

  • 定数フィールド値

• ORIGINAL_PARTITION

  public static final StringSE ORIGINAL_PARTITION

  別のトピックに公開されたレコードの元のパーティション。

  導入:

  2.2

  関連事項:

  • 定数フィールド値

• ORIGINAL_OFFSET

  public static final StringSE ORIGINAL_OFFSET

  別のトピックに公開されたレコードの元のオフセット。

  導入:

  2.2

  関連事項:

  • 定数フィールド値

• ORIGINAL_CONSUMER_GROUP

  public static final StringSE ORIGINAL_CONSUMER_GROUP

  別のトピックに公開されたレコードを消費できなかったコンシューマーグループ。

  導入:

  2.8

  関連事項:

  • 定数フィールド値

• ORIGINAL_TIMESTAMP

  public static final StringSE ORIGINAL_TIMESTAMP

  別のトピックに公開されたレコードの元のタイムスタンプ。

  導入:

  2.2

  関連事項:

  • 定数フィールド値

• ORIGINAL_TIMESTAMP_TYPE

  public static final StringSE ORIGINAL_TIMESTAMP_TYPE

  別のトピックに公開されたレコードの元のタイムスタンプ型。

  導入:

  2.2

  関連事項:

  • 定数フィールド値

• CONVERSION_FAILURES

  public static final StringSE CONVERSION_FAILURES

  変換失敗のリストを含むヘッダー（バッチリスナーのみ）。型: List <ConversionException>。

  導入:

  2.8

  関連事項:

  • 定数フィールド値

• LISTENER_INFO

  public static final StringSE LISTENER_INFO

  このレコードを受信するリスナーに関する任意の静的情報。

  導入:

  2.8.4

  関連事項:

  • 定数フィールド値