27.5. メッセージヘッダー

KafkaConstants.TOPIC

"kafka.TOPIC"

文字列

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

KafkaConstants.PARTITION

"kafka.PARTITION"

整数

メッセージが保存されるパーティション

KafkaConstants.OFFSET

"kafka.OFFSET"

Long

メッセージのオフセット

KafkaConstants.KEY

"kafka.KEY"

オブジェクト

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

KafkaConstants.HEADERS

"kafka.HEADERS"

org.apache.kafka.common.header.Headers

レコードヘッダー

KafkaConstants.LAST_RECORD_BEFORE_COMMIT

"kafka.LAST_RECORD_BEFORE_COMMIT"

ブール値

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

KafkaConstants.LAST_POLL_RECORD

"kafka.LAST_POLL_RECORD"

ブール値

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

KafkaConstants.MANUAL_COMMIT

"CamelKafkaManualCommit"

KafkaManualCommit

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