59.6. 消息标头

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"

字符串

发送消息的主题（覆盖和优先权），并且标头不会被保留。

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 endpoint 参数为 true时才配置