191.4. 邮件标题

191.4.1. 使用者标头

当使用来自 Kafka 的消息时，可以使用以下标头。

标头常量标头值类型描述

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 endpoint 参数为 false时才可用）

KafkaConstants.MANUAL_COMMIT

"CamelKafkaManualCommit"

KafkaManualCommit

可用于在使用 Kafka 使用者时强制手动偏移提交。