181.3. メッセージヘッダー

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.MANUAL_COMMIT

"CamelKafkaManualCommit"

KafkaManualCommit

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

KafkaConstants.KEY

"kafka.KEY"

Object

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

KafkaConstants.TOPIC

"kafka.TOPIC"

String

メッセージの送信先のトピック (bridgeEndpoint エンドポイントパラメーターが true の場合のみ読み取り)

KafkaConstants.PARTITION_KEY

"kafka.PARTITION_KEY"

Integer

明示的にパーティションを指定します (KafkaConstants.KEY ヘッダーが定義されている場合にのみ使用されます)

KafkaConstants.KAFKA_RECORDMETA

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

List<RecordMetadata>

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