Kafka传输java.time.Instant时间戳消费端显示异常，如何格式化？

问题原因 #

默认JSON序列化器（如Jackson）会将Instant类型序列化为纪元秒+纳秒的数值形式（如1685968244.889278400），而非你期望的ISO 8601格式字符串，导致消费端接收结果不符合预期。

解决方案 #

方案1：字段级注解配置（单个字段生效） #

在Response类的timestamp字段上添加Jackson格式化注解，强制指定序列化格式：

import com.fasterxml.jackson.annotation.JsonFormat;
import java.time.Instant;

public class Response<T> {
    private T data;
    private String statusCode;
    private String statusMessage;
    
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd'T'HH:mm:ss.SSSSSSSSS'Z'")
    private Instant timestamp;
    
    // 构造方法、getter/setter 自行补充
}

该注解会让Jackson将Instant序列化为2023-06-05T15:07:06.497159Z格式的字符串，同时反序列化时也能正确解析回Instant类型。

方案2：全局Jackson配置（所有Instant类型生效） #

如果项目中有多处Instant类型需要统一处理，可通过配置类全局修改Jackson的时间模块规则：

import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
import com.fasterxml.jackson.datatype.jsr310.ser.InstantSerializer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.time.format.DateTimeFormatter;

@Configuration
public class JacksonConfig {
    @Bean
    public ObjectMapper objectMapper() {
        ObjectMapper objectMapper = new ObjectMapper();
        JavaTimeModule timeModule = new JavaTimeModule();
        // 配置Instant序列化/反序列化为ISO 8601带纳秒的格式
        timeModule.addSerializer(Instant.class, InstantSerializer.INSTANCE.withFormat(
                DateTimeFormatter.ISO_INSTANT,
                DateTimeFormatter.ISO_INSTANT
        ));
        objectMapper.registerModule(timeModule);
        return objectMapper;
    }
}

此配置会让项目中所有Instant类型统一采用目标格式序列化，无需逐个字段添加注解。

方案3：确认Kafka序列化配置 #

确保Spring Kafka使用配置好的Jackson序列化器，而非默认实现。在application.yml中添加以下配置：

spring:
  kafka:
    producer:
      value-serializer: org.springframework.kafka.support.serializer.JsonSerializer
    consumer:
      value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer
      properties:
        spring.json.trusted.packages: "你的实体类包路径" # 如com.example.entity，替换为实际路径更安全

Spring会自动引用你在方案2中配置的ObjectMapper，保证序列化/反序列化规则一致。

验证效果 #

配置完成后，生产者发送的Response对象中，timestamp字段会被序列化为"timestamp": "2023-06-05T15:07:06.497159Z"格式，消费端反序列化后可正常获取Instant类型对象，同时JSON格式符合预期。

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