Spring Boot集成Elasticsearch时LocalDateTime日期转换报错解决

问题根源 #

Elasticsearch中存储的orderDate值2023-10-02T09:28:48+00:00是带时区偏移的日期时间格式，对应Java的OffsetDateTime类型；而你实体类中用的LocalDateTime是不带时区的日期时间类型，Spring Data Elasticsearch默认的类型转换器无法完成这种跨时区类型的转换，因此抛出ConversionException。

解决方案 #

方案1：修改实体类字段类型为OffsetDateTime（推荐） #

这是最直接且符合数据存储逻辑的方案，因为Elasticsearch的日期字段本身包含时区信息，用OffsetDateTime可以完整保留这些信息：

import java.time.OffsetDateTime;
import org.springframework.data.elasticsearch.annotations.Field;
import org.springframework.data.elasticsearch.annotations.FieldType;
import org.springframework.data.elasticsearch.annotations.DateFormat;

// 其他实体类注解
public class EcommerceOrder {

    // 明确指定日期格式匹配ES存储的格式
    @Field(type = FieldType.Date, format = DateFormat.date_time)
    private OffsetDateTime orderDate;

    // 其他字段、getter/setter
}

方案2：自定义转换器实现带时区字符串到LocalDateTime的转换 #

如果业务必须使用LocalDateTime，可以自定义类型转换器，将带时区的字符串转为LocalDateTime（可选择转为UTC时间或本地时区时间）：

步骤1：实现转换器类

import org.springframework.core.convert.converter.Converter;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;
import java.time.OffsetDateTime;
import java.time.ZoneId;

@Component
public class StringToLocalDateTimeConverter implements Converter<String, LocalDateTime> {

    @Override
    public LocalDateTime convert(String source) {
        // 方式1：将带时区的时间转为UTC时区的LocalDateTime（丢弃时区信息，保留UTC时间值）
        return OffsetDateTime.parse(source).toLocalDateTime();
        
        // 方式2：将带时区的时间转为本地时区的LocalDateTime
        // return OffsetDateTime.parse(source)
        //         .atZoneSameInstant(ZoneId.systemDefault())
        //         .toLocalDateTime();
    }
}

步骤2：注册转换器到Elasticsearch配置

import org.springframework.context.annotation.Configuration;
import org.springframework.data.elasticsearch.client.ClientConfiguration;
import org.springframework.data.elasticsearch.client.RestClients;
import org.springframework.data.elasticsearch.config.AbstractElasticsearchConfiguration;
import org.springframework.data.elasticsearch.core.convert.ConverterConfiguration;
import org.springframework.beans.factory.annotation.Autowired;

@Configuration
public class ElasticsearchConfig extends AbstractElasticsearchConfiguration {

    @Autowired
    private StringToLocalDateTimeConverter dateConverter;

    @Override
    public RestHighLevelClient elasticsearchClient() {
        ClientConfiguration clientConfig = ClientConfiguration.builder()
                .connectedTo("localhost:9200") // 替换为你的ES地址
                // 如果需要账号密码，添加：.withBasicAuth("username", "password")
                .build();
        return RestClients.create(clientConfig).rest();
    }

    @Override
    protected void configureConverters(ConverterConfiguration converterConfiguration) {
        converterConfiguration.addConverter(dateConverter);
    }
}

方案3：修改Elasticsearch索引的日期格式（不推荐） #

如果可以修改示例索引的mapping，将orderDate的格式改为不带时区的yyyy-MM-dd'T'HH:mm:ss，但需要重新导入数据，会破坏Kibana示例数据的原有结构，因此不推荐用于该场景。

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