29.5.2. 制作者标头

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

Expand

标头常数	标头值	类型	描述
`KafkaConstants.KEY`	`"kafka.KEY"`	`对象`	需要消息的密钥以确保所有相关消息在同一分区中
`KafkaConstants.OVERRIDE_TOPIC`	`"kafka.OVERRIDE_TOPIC"`	`字符串`	发送消息(override 和 take 优先级)和标头没有保留的主题。
`KafkaConstants.OVERRIDE_TIMESTAMP`	`"kafka.OVERRIDE_TIMESTAMP"`	`Long`	ProducerRecord 也具有关联的时间戳。如果用户提供了时间戳，则制作者会将记录与提供的时间戳的命名，并且不会保留标头。
`KafkaConstants.PARTITION_KEY`	`"kafka.PARTITION_KEY"`	`整数`	明确指定分区

如果要将消息发送到动态主题，则使用 KafkaConstants.OVERRIDE_TOPIC 作为其用作没有随消息一起发送的一次性标头，作为在制作者中被删除。

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

Expand

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

返回顶部