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

KafkaConstants.LAST_POLL_RECORD

"kafka.LAST_POLL_RECORD"

布尔值

表示当前轮询请求中的最后一个记录（仅在 autoCommitEnable endpoint 参数为 false 或 allowManualCommit 为 true时才可用）

KafkaConstants.MANUAL_COMMIT

"CamelKafkaManualCommit"

KafkaManualCommit

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