クラス KafkaHeaders
java.lang.ObjectSE
org.springframework.kafka.support.KafkaHeaders
Kafka 固有のメッセージヘッダー定数。
- 作成者:
- Artem Bilan, Marius Bogoevici, Gary Russell, Biju Kunjummen
フィールドサマリー
修飾子と型フィールド説明static final StringSE
Acknowledgment
のヘッダー。static final StringSE
変換されたネイティブ Kafka ヘッダーのマップのリストのヘッダー。static final StringSE
Consumer
オブジェクトのヘッダー。static final StringSE
変換失敗のリストを含むヘッダー(バッチリスナーのみ)。static final StringSE
リクエスト / 応答を相互に関連付けるための情報を含むヘッダー。static final StringSE
受信メッセージの場合、コンテナーの再試行が有効になっていると、配信が試行されます。static final StringSE
公開されたレコードの例外原因クラス名が、デッドレタートピックに送信されました。static final StringSE
デッドレタートピックに送信された、公開されたレコードの例外クラス名。static final StringSE
デッドレタートピックに公開されたレコードの例外メッセージ。static final StringSE
デッドレタートピックに公開されたレコードの例外スタックトレース。static final StringSE
公開されたレコードの例外クラス名が、キーの逆直列化例外を伴うデッドレタートピックに送信されました。static final StringSE
キーの逆直列化例外を使用して、デッドレタートピックに公開されたレコードの例外メッセージ。static final StringSE
キーの逆直列化例外を使用して、配信不能トピックに公開されたレコードの例外スタックトレース。static final StringSE
デッドレタートピックに公開されたレコードを消費できなかったコンシューマーグループ。static final StringSE
デッドレタートピックに公開されたレコードの元のオフセット。static final StringSE
デッドレタートピックに公開されたレコードの元のパーティション。static final StringSE
デッドレタートピックに公開されたレコードの元のタイムスタンプ。static final StringSE
デッドレタートピックに公開されたレコードの元のタイムスタンプ型。static final StringSE
デッドレタートピックに公開されたレコードの元のトピック。static final StringSE
別のトピックに送信された、公開されたレコードの例外クラス名。static final StringSE
別のトピックに送信された、公開されたレコードの例外クラス名。static final StringSE
別のトピックに公開されたレコードの例外メッセージ。static final StringSE
別のトピックに公開されたレコードの例外スタックトレース。static final StringSE
受信メッセージの場合、コンテナーのgroup.id
コンシューマープロパティ。static final StringSE
Kafka にデータを送信する際のレコードキーを含むヘッダー。static final StringSE
キー逆直列化例外を使用して別のトピックに送信された、公開されたレコードの例外クラス名。static final StringSE
キー逆直列化例外を使用して別のトピックに公開されたレコードの例外メッセージ。static final StringSE
キー逆直列化例外を使用して別のトピックに公開されたレコードの例外スタックトレース。static final StringSE
このレコードを受信するリスナーに関する任意の静的情報。static final StringSE
コンシューマーレコードのネイティブヘッダーを保持するためのヘッダー。ヘッダーマッパーが存在しない場合にのみ提供されます。static final StringSE
パーティションオフセットのヘッダー。static final StringSE
別のトピックに公開されたレコードを消費できなかったコンシューマーグループ。static final StringSE
別のトピックに公開されたレコードの元のオフセット。static final StringSE
別のトピックに公開されたレコードの元のパーティション。static final StringSE
別のトピックに公開されたレコードの元のタイムスタンプ。static final StringSE
別のトピックに公開されたレコードの元のタイムスタンプ型。static final StringSE
別のトピックに公開されたレコードの元のトピック。static final StringSE
Kafka にデータを送信するときのトピックパーティションを含むヘッダー。static final StringSE
Kafka ヘッダーのプレフィックス。static final StringSE
Kafka(ConsumerRecord
またはConsumerRecords
)から受信した生データを含むヘッダー。static final StringSE
'received' 値を含む Kafka ヘッダーのプレフィックス。static final StringSE
受信したメッセージのレコードキーを含むヘッダー。static final StringSE
受信したメッセージのトピックパーティションを含むヘッダー。static final StringSE
コンシューマーレコードのタイムスタンプを保持するためのヘッダー。static final StringSE
メッセージの受信元のトピックを含むヘッダー。static final StringSE
トピックへの送信が成功した後のRecordMetadata
オブジェクトを含むヘッダー。static final StringSE
応答を送信するパーティション番号を含むヘッダー。static final StringSE
デフォルトの返信トピックを含むヘッダー。static final StringSE
プロデューサーレコードのタイムスタンプを保持するためのヘッダー。static final StringSE
タイムスタンプのtype
を保持するためのヘッダー。static final StringSE
Kafka にデータを送信するときのトピックを含むヘッダー。コンストラクターのサマリー
メソッドのサマリー
フィールドの詳細
PREFIX
Kafka ヘッダーのプレフィックス。- 関連事項:
RECEIVED
'received' 値を含む Kafka ヘッダーのプレフィックス。- 関連事項:
TOPIC
Kafka にデータを送信するときのトピックを含むヘッダー。- 関連事項:
KEY
Kafka にデータを送信する際のレコードキーを含むヘッダー。- 導入:
- 2.9
- 関連事項:
PARTITION
Kafka にデータを送信するときのトピックパーティションを含むヘッダー。- 導入:
- 2.0
- 関連事項:
OFFSET
パーティションオフセットのヘッダー。- 関連事項:
RAW_DATA
Kafka(ConsumerRecord
またはConsumerRecords
)から受信した生データを含むヘッダー。通常、エラーメッセージを強化するために使用されます。- 関連事項:
RECORD_METADATA
トピックへの送信が成功した後のRecordMetadata
オブジェクトを含むヘッダー。- 関連事項:
ACKNOWLEDGMENT
Acknowledgment
のヘッダー。- 関連事項:
CONSUMER
Consumer
オブジェクトのヘッダー。- 関連事項:
RECEIVED_TOPIC
メッセージの受信元のトピックを含むヘッダー。- 関連事項:
RECEIVED_KEY
受信したメッセージのレコードキーを含むヘッダー。- 導入:
- 2.9
- 関連事項:
RECEIVED_PARTITION
受信したメッセージのトピックパーティションを含むヘッダー。- 導入:
- 2.9
- 関連事項:
TIMESTAMP_TYPE
タイムスタンプのtype
を保持するためのヘッダー。- 関連事項:
TIMESTAMP
プロデューサーレコードのタイムスタンプを保持するためのヘッダー。- 関連事項:
RECEIVED_TIMESTAMP
コンシューマーレコードのタイムスタンプを保持するためのヘッダー。- 関連事項:
NATIVE_HEADERS
コンシューマーレコードのネイティブヘッダーを保持するためのヘッダー。ヘッダーマッパーが存在しない場合にのみ提供されます。- 関連事項:
BATCH_CONVERTED_HEADERS
変換されたネイティブ Kafka ヘッダーのマップのリストのヘッダー。バッチリスナーに使用されます。特定のリスト位置のマップは、ペイロードリスト位置のデータに対応します。- 関連事項:
CORRELATION_ID
リクエスト / 応答を相互に関連付けるための情報を含むヘッダー。型: byte[]。- 導入:
- 2.1.3
- 関連事項:
REPLY_TOPIC
デフォルトの返信トピックを含むヘッダー。型: byte[]。- 導入:
- 2.1.3
- 関連事項:
REPLY_PARTITION
応答を送信するパーティション番号を含むヘッダー。型: byte[] のバイナリ(int)。- 導入:
- 2.1.3
- 関連事項:
DLT_EXCEPTION_FQCN
デッドレタートピックに送信された、公開されたレコードの例外クラス名。- 導入:
- 2.2
- 関連事項:
DLT_EXCEPTION_CAUSE_FQCN
公開されたレコードの例外原因クラス名が、デッドレタートピックに送信されました。- 導入:
- 2.8
- 関連事項:
DLT_EXCEPTION_STACKTRACE
デッドレタートピックに公開されたレコードの例外スタックトレース。- 導入:
- 2.2
- 関連事項:
DLT_EXCEPTION_MESSAGE
デッドレタートピックに公開されたレコードの例外メッセージ。- 導入:
- 2.2
- 関連事項:
DLT_KEY_EXCEPTION_STACKTRACE
キーの逆直列化例外を使用して、配信不能トピックに公開されたレコードの例外スタックトレース。- 導入:
- 2.7
- 関連事項:
DLT_KEY_EXCEPTION_MESSAGE
キーの逆直列化例外を使用して、デッドレタートピックに公開されたレコードの例外メッセージ。- 導入:
- 2.7
- 関連事項:
DLT_KEY_EXCEPTION_FQCN
公開されたレコードの例外クラス名が、キーの逆直列化例外を伴うデッドレタートピックに送信されました。- 導入:
- 2.7
- 関連事項:
DLT_ORIGINAL_TOPIC
デッドレタートピックに公開されたレコードの元のトピック。- 導入:
- 2.2
- 関連事項:
DLT_ORIGINAL_PARTITION
デッドレタートピックに公開されたレコードの元のパーティション。- 導入:
- 2.2
- 関連事項:
DLT_ORIGINAL_OFFSET
デッドレタートピックに公開されたレコードの元のオフセット。- 導入:
- 2.2
- 関連事項:
DLT_ORIGINAL_CONSUMER_GROUP
デッドレタートピックに公開されたレコードを消費できなかったコンシューマーグループ。- 導入:
- 2.8
- 関連事項:
DLT_ORIGINAL_TIMESTAMP
デッドレタートピックに公開されたレコードの元のタイムスタンプ。- 導入:
- 2.2
- 関連事項:
DLT_ORIGINAL_TIMESTAMP_TYPE
デッドレタートピックに公開されたレコードの元のタイムスタンプ型。- 導入:
- 2.2
- 関連事項:
GROUP_ID
受信メッセージの場合、コンテナーのgroup.id
コンシューマープロパティ。- 導入:
- 2.3
- 関連事項:
DELIVERY_ATTEMPT
受信メッセージの場合、コンテナーの再試行が有効になっていると、配信が試行されます。- 導入:
- 2.5
- 関連事項:
EXCEPTION_FQCN
別のトピックに送信された、公開されたレコードの例外クラス名。- 導入:
- 2.2
- 関連事項:
EXCEPTION_CAUSE_FQCN
別のトピックに送信された、公開されたレコードの例外クラス名。- 導入:
- 2.8
- 関連事項:
EXCEPTION_STACKTRACE
別のトピックに公開されたレコードの例外スタックトレース。- 導入:
- 2.2
- 関連事項:
EXCEPTION_MESSAGE
別のトピックに公開されたレコードの例外メッセージ。- 導入:
- 2.2
- 関連事項:
KEY_EXCEPTION_STACKTRACE
キー逆直列化例外を使用して別のトピックに公開されたレコードの例外スタックトレース。- 導入:
- 2.7
- 関連事項:
KEY_EXCEPTION_MESSAGE
キー逆直列化例外を使用して別のトピックに公開されたレコードの例外メッセージ。- 導入:
- 2.7
- 関連事項:
KEY_EXCEPTION_FQCN
キー逆直列化例外を使用して別のトピックに送信された、公開されたレコードの例外クラス名。- 導入:
- 2.7
- 関連事項:
ORIGINAL_TOPIC
別のトピックに公開されたレコードの元のトピック。- 導入:
- 2.2
- 関連事項:
ORIGINAL_PARTITION
別のトピックに公開されたレコードの元のパーティション。- 導入:
- 2.2
- 関連事項:
ORIGINAL_OFFSET
別のトピックに公開されたレコードの元のオフセット。- 導入:
- 2.2
- 関連事項:
ORIGINAL_CONSUMER_GROUP
別のトピックに公開されたレコードを消費できなかったコンシューマーグループ。- 導入:
- 2.8
- 関連事項:
ORIGINAL_TIMESTAMP
別のトピックに公開されたレコードの元のタイムスタンプ。- 導入:
- 2.2
- 関連事項:
ORIGINAL_TIMESTAMP_TYPE
別のトピックに公開されたレコードの元のタイムスタンプ型。- 導入:
- 2.2
- 関連事項:
CONVERSION_FAILURES
変換失敗のリストを含むヘッダー(バッチリスナーのみ)。型: List <ConversionException>。- 導入:
- 2.8
- 関連事項:
LISTENER_INFO
このレコードを受信するリスナーに関する任意の静的情報。- 導入:
- 2.8.4
- 関連事項:
コンストラクターの詳細
KafkaHeaders
public KafkaHeaders()