190.4.2. producer 标头

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

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

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

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

Select Your Language