Spring Kafka消费者忽略类型Header配置无效，请求排查

问题根源 #

你配置的spring.json.use.type.headers: false仅作用于JsonDeserializer，控制它是否使用消息中的类型Header（如__TypeId__）确定反序列化目标类型。但当前报错发生在消息Header映射阶段：DefaultKafkaHeaderMapper默认会自动解析类型Header，尝试将其内容作为JSON反序列化，而你的消息中该Header的值是Base64编码的JSON字符串，导致Jackson解析失败。

解决方案 #

需要禁用DefaultKafkaHeaderMapper的类型Header解析功能，有两种实现方式：

方式一：通过Spring Boot配置直接生效 #

在spring.kafka.consumer.properties中添加禁用类型Header映射的配置项：

spring:
  kafka:
    consumer:
      # 保留原有配置
      properties:
        spring.json.use.type.headers: false
        # 新增：禁用HeaderMapper对类型Header的解析
        spring.kafka.header.mapper.type.headers.enabled: false

完整配置示例：

spring:
  application:
    name: @project.artifactId@
  config:
    import: bootstrap.yml
  main:
    banner-mode: "off"
  jmx:
    enabled: true
  kafka:
    consumer:
      key-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer
      value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer
      auto-offset-reset: earliest
      group-id: ${spring.application.name}.${stage}
      properties:
        spring.json.use.type.headers: false
        spring.kafka.header.mapper.type.headers.enabled: false

方式二：自定义HeaderMapper Bean #

如果Spring Boot版本较低导致配置项不生效，可手动创建DefaultKafkaHeaderMapper并禁用类型Header处理：

import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration
import org.springframework.kafka.support.DefaultKafkaHeaderMapper
import org.springframework.kafka.support.KafkaHeaderMapper

@Configuration
class KafkaConfig {

    @Bean
    fun kafkaHeaderMapper(): KafkaHeaderMapper {
        val headerMapper = DefaultKafkaHeaderMapper()
        headerMapper.setTypeHeadersEnabled(false)
        return headerMapper
    }
}

额外验证点 #

• 你已经在@Payload参数中指定Employee?作为目标类型，JsonDeserializer会直接使用该类型反序列化，无需依赖类型Header，符合忽略类型Header的需求。
• 修改后，DefaultKafkaHeaderMapper会跳过类型Header的解析，不再触发Jackson的JSON解析错误。

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