如何覆盖 Spring Cloud Stream 的 Jackson ObjectMapper 配置？

Question

在 Spring Boot/Spring Cloud Stream 应用程序中，我们使用 Kafka binder。我注意到在反序列化包含ZonedDateTime 属性的Kafka 消息时，即使序列化形式包含时区（例如20210101084239+0200），Jackson 也会自动更改时区（到UTC）。 经过一番研究，我发现这是一个可以禁用的默认反序列化功能，因此我在我的 @Configuration 类之一中添加了以下内容：

    @Bean
    public Jackson2ObjectMapperBuilderCustomizer objectMapperCustomizer() {
        return builder ->  {
            builder.featuresToDisable(DeserializationFeature.ADJUST_DATES_TO_CONTEXT_TIME_ZONE);
            //... other custom config...
        };

但这不起作用，大概是因为 Spring Cloud Stream（或 Kafka binder）使用的 ObjectMapper 不是从应用程序上下文中配置的 Jackson2ObjectMapperBuilder 构造的:-(。

经过更多研究，我发现有人声称有必要覆盖 Spring Messaging 的 MappingJackson2MessageConverter，因为它会创建自己的 ObjectMapper。所以我添加了这个：

    @Bean
    public MappingJackson2MessageConverter springMessagingJacksonConverter() {
        MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();
        converter.getObjectMapper().configure(DeserializationFeature.ADJUST_DATES_TO_CONTEXT_TIME_ZONE, false);

        return converter;
    }

不幸的是，这仍然不起作用。我仍然在反序列化 ZonedDateTime 对象，忽略 JSON 值中的时区信息。

那么 Spring Cloud Stream Kafka binder 使用的 ObjectMapper 是由什么 bean 创建的，如何自定义其配置？

Answer 1

正如下面的讨论 cmets 和 here 中所述，Spring Cloud Stream 中存在一个错误，即它没有在应使用的地方使用 Spring 应用程序上下文中的 ObjectMapper。

话虽如此，解决方法是定义您自己的Serde<> @Bean，它调用JsonSerde<> 构造函数，该构造函数采用从应用上下文注入的ObjectMapper。例如：

@Configuration
public class MyConfig {
    @Bean
    public Serde<SomeClass> someClassSerde(ObjectMapper jsonMapper) {
        return new JsonSerde<SomeClass>(SomeClass.class, jsonMapper);
    }
}

此解决方法的缺点是您必须针对要在消息中序列化/反序列化的每种目标类型执行此操作。

Answer 2

请看spring boot reference

如果您想完全替换默认的 ObjectMapper，请定义该类型的 @Bean 并将其标记为 @Primary，或者，如果您更喜欢基于构建器的方法，请定义 Jackson2ObjectMapperBuilder @Bean。请注意，在任何一种情况下，这样做都会禁用 ObjectMapper 的所有自动配置。