Spring Cloud Stream中Jackson注解在消息转换的异常与字段问题

问题场景 #

• 技术栈：Spring Boot 3.0.6、Spring Cloud 2022.0.2
• 核心需求：接口响应中屏蔽numbers字段，返回基于numbers值生成的tokens字段
• 初始实现：通过@JsonIgnoreProperties(ignoreUnknown = true, value = {"numbers"}, allowSetters = true)实现numbers字段的输出屏蔽，同时允许反序列化时设置该字段用于生成tokens
• 端点表现差异：
  • /mvc端点（使用DummyMessage1）：表现正常，numbers被屏蔽，tokens能根据请求的numbers值生成分割列表返回
  • /message Kafka端点（使用DummyMessage2）：
    • 初始和DummyMessage1逻辑一致时，抛出java.lang.ClassCastException: class [B cannot be cast to class com.example.marshaller.model.DummyMessage2异常
    • 为解决异常，在getTokens()上添加@JsonProperty(access = JsonProperty.Access.READ_ONLY)后，numbers被屏蔽但tokens字段为空，不符合预期

问题原因分析 #

1. Kafka与Spring MVC的Jackson处理逻辑差异 #

Spring MVC的请求/响应处理直接基于Jackson对请求体做序列化/反序列化，严格遵循类上的注解规则：allowSetters = true允许numbers被反序列化（用于生成tokens），同时value = {"numbers"}确保该字段不被序列化输出。

而Spring Cloud Kafka默认的消息转换机制（如MappingJackson2MessageConverter）对派生字段（无实际存储的tokens）的处理逻辑不同：当检测到对象没有对应字段的完整getter/setter映射时，可能会错误地将字节数组直接尝试强转为目标对象，触发ClassCastException。

2. @JsonProperty(access = READ_ONLY)的副作用 #

给getTokens()添加READ_ONLY注解后，Jackson将该字段标记为仅用于序列化输出，但Kafka的序列化上下文不会主动触发getTokens()的计算逻辑——因为tokens没有对应的存储字段，原本依赖的numbers字段虽然能被反序列化，但在生成响应时，Jackson没有调用getTokens()来计算值，最终导致tokens返回空。

解决方案解析 #

方案1：新增tokens字段并调整getTokens()逻辑 #

在DummyMessage2中添加tokens存储字段，修改getTokens()优先返回存储值，为空时再基于numbers生成：

private List<String> tokens;

public List<String> getTokens() {
    if (tokens != null && !tokens.isEmpty()) {
        return tokens;
    }
    return Arrays.stream(numbers.split(","))
                 .map(String::trim)
                 .collect(Collectors.toList());
}

原理：给tokens添加实际存储字段后，满足了Kafka序列化对字段存在性的要求，同时保留了原有基于numbers生成tokens的业务逻辑，序列化时优先读取存储值，为空时自动计算。

方案2：编写反向setter逻辑（维护成本高，不推荐） #

为tokens添加setter方法，反向将tokens拼接为numbers字符串：

public void setTokens(List<String> tokens) {
    this.numbers = String.join(",", tokens);
}

弊端：反向映射逻辑容易因业务规则变更而出错，后续字段调整时需要同步维护setter，增加长期维护负担。

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