Spring Boot整合OpenSearch时ZonedDateTime字段转换异常问题

问题根源 #

你存储在OpenSearch中的日期字符串2023-10-23T21:05:37.263不包含时区偏移信息，但实体类中使用的是带时区的ZonedDateTime类型，Spring Data默认的转换器无法完成无时区字符串到ZonedDateTime的转换，因此抛出异常。

解决方案 #

方案1：调整实体类字段类型（最简便） #

既然存储的日期没有时区信息，直接将字段类型改为LocalDateTime更匹配，无需额外配置即可正常读写：

@Builder
@Document(indexName = "orders", writeTypeHint = WriteTypeHint.FALSE)
public class OrderModel {
    @Id
    private String orderId;

    @Field(type = FieldType.Date, pattern = "uuuu-MM-dd'T'HH:mm:ss.SSS", format = {})
    private LocalDateTime orderDate; // 替换为LocalDateTime

    private String store;
}

方案2：保留ZonedDateTime，存储时带上时区信息 #

如果业务必须使用ZonedDateTime，修改@Field的日期格式，让写入的日期包含时区偏移：

@Builder
@Document(indexName = "orders", writeTypeHint = WriteTypeHint.FALSE)
public class OrderModel {
    @Id
    private String orderId;

    // 格式加上时区偏移标识XXX
    @Field(type = FieldType.Date, pattern = "uuuu-MM-dd'T'HH:mm:ss.SSSXXX", format = {})
    private ZonedDateTime orderDate;

    private String store;
}

修改后，存储的日期会变成类似2023-10-23T21:05:37.263+08:00的格式，读取时可直接转换为ZonedDateTime。

方案3：自定义转换器（适配存量无时区数据） #

如果无法修改字段类型或存量数据已存在，可通过自定义转换器强制给无时区字符串指定默认时区：

1. 实现自定义转换器

@Component
public class ZonedDateTimeConverter implements Converter<String, ZonedDateTime>, Converter<ZonedDateTime, String> {
    // 读取时用默认时区（可替换为业务需要的时区，比如UTC）
    private static final DateTimeFormatter READ_FORMATTER = DateTimeFormatter.ofPattern("uuuu-MM-dd'T'HH:mm:ss.SSS")
            .withZone(ZoneId.systemDefault());
    // 写入时保持原有格式
    private static final DateTimeFormatter WRITE_FORMATTER = DateTimeFormatter.ofPattern("uuuu-MM-dd'T'HH:mm:ss.SSS");

    @Override
    public ZonedDateTime convert(String source) {
        return LocalDateTime.parse(source, WRITE_FORMATTER).atZone(READ_FORMATTER.getZone());
    }

    @Override
    public String convert(ZonedDateTime source) {
        return source.format(WRITE_FORMATTER);
    }
}

2. 配置转换器到Spring Data体系

@Configuration
public class OpenSearchConfig extends AbstractElasticsearchConfiguration {

    @Autowired
    private ZonedDateTimeConverter zonedDateTimeConverter;

    @Override
    public MappingElasticsearchConverter mappingElasticsearchConverter() {
        MappingElasticsearchConverter converter = super.mappingElasticsearchConverter();
        converter.getConversionService().addConverter(zonedDateTimeConverter);
        return converter;
    }

    @Override
    public RestHighLevelClient elasticsearchClient() {
        // 根据你的OpenSearch集群配置客户端
        ClientConfiguration clientConfig = ClientConfiguration.builder()
                .connectedTo("localhost:9200")
                .build();
        return RestClients.create(clientConfig).rest();
    }
}

注意事项 #

如果使用方案2或3，已有存量数据需要重新同步或更新索引映射，避免旧数据依然触发转换异常。

内容的提问来源于stack exchange，提问作者NecmiK