Spring Kafka Streams处理器无法运行，类'[B'不在可信包报错

1. 核心配置不匹配 #

你使用Kafka Streams Binder开发流处理应用，却将序列化/反序列化器配置写到了普通Kafka Binder的配置路径下，该配置对Kafka Streams Binder完全不生效，所以服务启动后加载了默认的ByteArrayDeserializer，导致消息的__TypeId__头被标记为字节数组的类名[B，反序列化时触发信任包校验失败。
同时Kafka Streams Binder要求绑定配置使用Serde接口，而非单独配置serializer/deserializer，这也是配置未生效的原因之一。

2. 修正配置 #

将流处理服务的序列化配置调整到Kafka Streams Binder对应的配置路径下，同时补充反序列化需要的信任包配置：

spring.cloud.stream:
  function:
    definition: processExternalMessage
  bindings:
    processExternalMessage-in-0:
      destination: external_messages
    processExternalMessage-out-0:
      destination: internal_messages
  # Kafka Streams Binder专属配置
  kafka.streams:
    bindings:
      processExternalMessage-out-0:
        producer:
          valueSerde: org.springframework.kafka.support.serializer.JsonSerde
      processExternalMessage-in-0:
        consumer:
          valueSerde: org.springframework.kafka.support.serializer.JsonSerde
    binder:
      configuration:
        # 生产环境建议替换为具体业务包路径
        spring.json.trusted.packages: "*"
        # 可指定默认反序列化目标类，直接忽略消息头的__TypeId__配置
        # spring.json.value.default.type: com.yetti.common.externalmessage.ExternalMessage

普通生产者服务（非流处理）的配置可调整为完整配置key写法，避免YAML层级解析导致的配置失效问题：

spring.cloud.stream:
  kafka:
    bindings:
      externalMessageProducer-out-0:
        producer:
          configuration:
            value.serializer: org.springframework.kafka.support.serializer.JsonSerializer

3. 存量消息兼容处理 #

如果external_messages topic中已经存在大量携带错误__TypeId__头的历史消息，建议先清理存量消息，或者直接在消费者侧配置默认反序列化目标类，完全忽略__TypeId__头的内容即可正常消费历史消息。

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