自定义对象映射器

Pulsar 在反序列化 JSON 消息时使用内部 Jackson。如果您想提供自己的对象映射器实例，则可以注册并设置映射器，如下所示：ObjectMapperSchemaResolverCustomizerDefaultSchemaResolverspring-doc.cn

@Bean
SchemaResolverCustomizer<DefaultSchemaResolver> schemaResolverCustomizer() {
    return (DefaultSchemaResolver schemaResolver) -> {
        var myObjectMapper = obtainMyObjectMapper();
        schemaResolver.setObjectMapper(myObjectMapper);
    };
}

这会导致您的对象映射器用于解序/序列化所有经过 schema 解析过程的 JSON 消息（即，在生成/使用消息时不直接传入 schema）。spring-doc.cn

在后台，解析器会创建一个特殊的 JSON 架构，该架构利用自定义映射器，并用作所有已解析 JSON 消息的架构。spring-doc.cn

如果需要直接传递 schema 实例，可以使用来创建遵循自定义映射器的 schema。以下示例显示了在发送包含采用 schema 参数的变体的消息时如何执行此操作：JSONSchemaUtilPulsarTemplatespring-doc.cn

void sendMessage(PulsarTemplate<MyPojo> template, MyPojo toSend) {
    var myObjectMapper = obtainMyObjectMapper();
    var schema = JSONSchemaUtil.schemaForTypeWithObjectMapper(MyPojo.class, myObjectMapper);
    template.send(toSend, schema);
}

Pulsar 以特定方式配置其默认对象映射器。除非有特定原因不这样做，否则强烈建议您使用以下相同选项配置映射器：spring-doc.cn

myObjectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
myObjectMapper.configure(DeserializationFeature.READ_UNKNOWN_ENUM_VALUES_AS_NULL, false);
myObjectMapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);

更高版本的框架可能会提供在默认映射器上运行的定制器，而不是需要单独的实例。