34.5. メッセージヘッダー

KafkaConstants.TOPIC

"kafka.TOPIC"

String

メッセージの発信元のトピック

KafkaConstants.PARTITION

"kafka.PARTITION"

Integer

メッセージが格納されたパーティション

KafkaConstants.OFFSET

"kafka.OFFSET"

Long

メッセージのオフセット

KafkaConstants.KEY

"kafka.KEY"

Object

メッセージのキー (設定されている場合)

KafkaConstants.HEADERS

"kafka.HEADERS"

org.apache.kafka.common.header.Headers

レコードのヘッダー

KafkaConstants.LAST_RECORD_BEFORE_COMMIT

"kafka.LAST_RECORD_BEFORE_COMMIT"

Boolean

コミット前の最後のレコードかどうか (autoCommitEnable エンドポイントパラメーターが false の場合にのみ使用可能)

KafkaConstants.LAST_POLL_RECORD

"kafka.LAST_POLL_RECORD"

Boolean

現在のポーリングリクエスト内の最後のレコードを示します (autoCommitEnable エンドポイントパラメーターが false または allowManualCommit が true の場合にのみ使用可能)

KafkaConstants.MANUAL_COMMIT

"CamelKafkaManualCommit"

KafkaManualCommit

Kafka consumer を使用する場合に手動オフセットコミットを強制するために使用できます。

KafkaConstants.KEY

"kafka.KEY"

Object

必須 すべての関連メッセージが同じパーティションに入るようにするためのメッセージのキー

KafkaConstants.OVERRIDE_TOPIC

"kafka.OVERRIDE_TOPIC"

String

メッセージの送信先のトピック (オーバーライドおよび優先)、およびヘッダーは保持されません。

KafkaConstants.OVERRIDE_TIMESTAMP

"kafka.OVERRIDE_TIMESTAMP"

Long

ProducerRecord には、関連付けられたタイムスタンプもあります。ユーザーがタイムスタンプを提供した場合、producer は提供されたタイムスタンプをレコードにスタンプし、ヘッダーは保持されません。

KafkaConstants.PARTITION_KEY

"kafka.PARTITION_KEY"

Integer

パーティションを明示的に指定する

KafkaConstants.KAFKA_RECORDMETA

"org.apache.kafka.clients.producer.RecordMetadata"

List<RecordMetadata>

メタデータ (recordMetadata エンドポイントパラメーターが true の場合にのみ設定されます)