“Tombstone”记录的 Null 负载和日志压缩

使用日志压缩时，您可以发送和接收带有负载的消息，以识别密钥的删除。 您还可以出于其他原因接收值，例如，当它无法反序列化值时，可能会返回的反序列化程序。nullnullnullspring-doc.cn

生成 Null 有效负载

要使用 发送有效负载，您可以使用 Fluent API 并将 null 传递到方法的 value 参数中，例如：nullPulsarTemplatenewMessage()spring-doc.cn

pulsarTemplate
        .newMessage(null)
        .withTopic("my-topic")
        .withSchema(Schema.STRING)
        .withMessageCustomizer((mb) -> mb.key("key:1234"))
        .send();
发送 null 值时，必须指定架构类型，因为系统无法确定有效负载中的消息类型。null

使用 Null 负载

对于 和 ，有效负载根据其 message 参数的类型传递到 listener 方法中，如下所示：@PulsarListener@PulsarReadernullspring-doc.cn

参数类型 传入值

原始spring-doc.cn

nullspring-doc.cn

用户定义spring-doc.cn

nullspring-doc.cn

org.apache.pulsar.client.api.Message<T>spring-doc.cn

返回getValue()nullspring-doc.cn

org.springframework.messaging.Message<T>spring-doc.cn

返回getPayload()PulsarNullspring-doc.cn

List<X>spring-doc.cn

非 null 列表，其条目 （） 是上述类型之一，并相应地操作（即原始条目是等）。Xnullspring-doc.cn

org.apache.pulsar.client.api.Messages<T>spring-doc.cn

非 null Pulsar 消息的非 null 容器，其返回getValue()nullspring-doc.cn
当传入值为 （即具有基元或用户定义类型的单记录侦听器） 时，您必须将参数注释与 .null@Payloadrequired = false
当将 Spring 用于侦听器有效负载类型时，其泛型类型信息必须足够宽以接受（例如 ， ， 或 ）。 这是因为 Spring Message 不允许其有效负载为 null 值，而是使用占位符。org.springframework.messaging.MessageMessage<PulsarNull>MessageMessage<?>Message<Object>PulsarNull

如果它是压缩日志的逻辑删除消息，则通常还需要该键，以便您的应用程序可以确定哪个键是 “”。 以下示例显示了此类配置：deletedspring-doc.cn

@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