“墓碑”记录的空有效载荷与日志压缩
使用日志压缩时，你可以发送和接收消息零用于识别密钥删除的有效载荷。
你也可以收到零值是其他原因，比如可能返回的解串器零当它无法反序列化某个值时。
生成零有效载荷
发送一个零通过使用脉冲星模板你可以使用流流API并将空输入到值参数中newMessage（）例如：
pulsarTemplate
.newMessage(null)
.withTopic("my-topic")
.withSchema(Schema.STRING)
.withMessageCustomizer((mb) -> mb.key("key:1234"))
.send();发送空值时必须指定模式类型，因为系统无法从中确定消息的类型零有效载荷。 |
消耗空有效载荷
为@PulsarListener和@PulsarReader这零有效载荷根据其消息参数类型传递到监听器方法，具体如下：
| 参数类型 | 转账价值 |
|---|---|
原始 |
|
用户自定义 |
|
|
非零的脉冲星消息 |
|
非空 Spring 消息 其 |
|
非空列表，其条目（ |
|
非空容器，包含非空脉冲星消息，其 |
当传入值为零（即具有原始类型或用户定义类型的单记录监听器）你必须使用@Payload参数注释必要 = 错误. |
使用Spring时org.springframework.messaging.Message对于你的监听器有效载荷类型，其通用类型信息必须足够宽泛以接受Message<PulsarNull>（例如：消息,留言<？>或Message<Object>).
这是因为 Spring 消息不允许其有效载荷为空值，而是使用脉冲星零占 位 符。 |
如果是压缩日志的墓碑消息，通常还需要密钥，以便应用程序判断哪个密钥是”删除".
以下示例展示了这样的构型：
@PulsarListener(
topics = "my-topic",
subscriptionName = "my-topic-sub",
schemaType = SchemaType.STRING)
void myListener(
@Payload(required = false) String msg,
@Header(PulsarHeaders.KEY) String key) {
...
}这@PulsarReader尚未支持@Header参数，因此在对数压缩场景中其实用性较低。 |