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 使用者时，可用于强制手动偏移提交。