191.4. 消息标头

191.4.1. 消费者标头
复制链接

在消耗 Kafka 的消息时，以下标头可用。

Expand

标头常数	标头值	类型	描述
`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 使用者时，可用于强制手动偏移提交。

191.4.2. 制作者标头
复制链接

在向 Kafka 发送消息前，您可以配置以下标头。

Expand

标头常数	标头值	类型	描述
`KafkaConstants.KEY`	`"kafka.KEY"`	`对象`	必需消息的密钥，以确保所有相关消息都在同一分区中
`KafkaConstants.TOPIC`	`"kafka.TOPIC"`	`字符串`	发送消息的主题（仅当 `bridgeEndpoint` 端点参数为 `true`时读取）
`KafkaConstants.PARTITION_KEY`	`"kafka.PARTITION_KEY"`	`整数`	明确指定分区（仅在定义了 `KafkaConstants.KEY` 标头时使用）

将消息发送到 Kafka 后，以下标头可用

Expand

标头常数	标头值	类型	描述
`KafkaConstants.KAFKA_RECORDMETA`	`"org.apache.kafka.clients.producer.RecordMetadata"`	`List<RecordMetadata>`	元数据（仅在 `recordMetadata` endpoint 参数为 `true`时配置

返回顶部

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务，以及可以信赖的内容，帮助红帽用户创新并实现他们的目标。了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情，请参阅红帽博客.

關於紅帽

我们提供强化的解决方案，使企业能够更轻松地跨平台和环境（从核心数据中心到网络边缘）工作。

Theme

© 2025 Red Hat