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

KafkaConstants.KEY

"kafka.KEY"

对象

必需 消息的密钥，以确保所有相关消息都位于同一分区中

KafkaConstants.OVERRIDE_TOPIC

"kafka.OVERRIDE_TOPIC"

字符串

发送消息的主题(override 和 take priority)，标头不会被保留。

KafkaConstants.OVERRIDE_TIMESTAMP

"kafka.OVERRIDE_TIMESTAMP"

Long

ProducerRecord 也有一个关联的时间戳。如果用户提供时间戳，则制作者将调整与提供的时间戳的记录，并且不会保留标头。

KafkaConstants.PARTITION_KEY

"kafka.PARTITION_KEY"

整数

明确指定分区

KafkaConstants.KAFKA_RECORDMETA

"org.apache.kafka.clients.producer.RecordMetadata"

List<RecordMetadata>

元数据（仅在 recordMetadata 端点参数为 true时配置