Spring Cloud Stream路由至Channel时触发ClassCastException问题排查

核心原因 #

使用spring.cloud.stream.sendto.destination指定输出目标时，框架不会自动读取你在BindingProperties中配置的outputContentType，默认采用ByteArraySerializer序列化，导致自定义对象FlightEvent无法转为字节数组抛出异常；而StreamBridge和函数输出绑定（如PlaneEvent-out-0）会自动关联绑定配置的内容类型，所以能正常序列化。

可行解决方案 #

1. 手动为消息添加Content-Type头 #

在处理函数返回消息时，显式设置Content-Type为application/json，指定序列化方式：

import org.springframework.messaging.support.MessageBuilder;
import org.springframework.http.MediaType;

// 处理函数内构建消息
return MessageBuilder.withPayload(new FlightEvent())
        .setHeader(MessageHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
        .setHeader("spring.cloud.stream.sendto.destination", "your-target-topic")
        .build();

2. 配置全局默认输出内容类型 #

在配置文件（如application.yml）中设置全局默认的输出contentType，所有通过sendto.destination发送的消息都会自动使用该类型：

spring:
  cloud:
    stream:
      default:
        output:
          contentType: application/json

3. 为目标Topic单独配置绑定属性 #

如果不想全局生效，可为指定的目标Topic单独配置绑定，确保contentType正确：

spring:
  cloud:
    stream:
      bindings:
        your-target-topic:
          contentType: application/json
          producer:
            use-native-encoding: false # 禁用原生编码，强制使用配置的contentType序列化

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