29.5.2. producer 标头
在向 Kafka 发送消息前,您可以配置以下标头。
标头常量 | 标头值 | 类型 | Description |
---|---|---|---|
|
|
| 所需的 消息键,以确保所有相关消息都在同一个分区中 |
|
|
| 发送消息(覆盖和优先处理)的主题不会保留。 |
|
|
| ProducerRecord 也具有关联的时间戳。如果用户提供时间戳,则生产者会将记录与提供的时间戳的时间戳的时间戳,并且该标头不会被保留。 |
|
|
| 明确指定分区 |
如果要将消息发送到动态主题,则使用 KafkaConstants.OVERRIDE_TOPIC
作为其不发送消息的一次性标头,作为其在制作者中删除。
在将消息发送到 Kafka 后,可以使用以下标头
标头常量 | 标头值 | 类型 | Description |
---|---|---|---|
|
|
|
元数据(仅在 |