Spring Kafka Stream生产者Type header无法移除问题求助

核心问题：配置层级错误 #

你当前将spring.json.add.type.headers=false放在了spring.cloud.stream.kafka.binder.producerProperties下，这个层级是全局Kafka生产者的通用配置，不会被JsonSerializer识别并生效。spring.json.*系列配置是JsonSerializer的专属参数，需要绑定到具体输出绑定的生产者配置中。

正确配置方式 #

方式1：针对具体输出绑定配置 #

假设你的processor函数的输出绑定名称为processor-out-0（Spring Cloud Stream默认命名规则：函数名+-out-+索引），添加以下配置：

spring:
  cloud:
    stream:
      kafka:
        bindings:
          processor-out-0:
            producer:
              configuration:
                spring.json.add.type.headers: false

如果有多个输出绑定，需要分别为每个绑定配置该参数。

方式2：全局绑定级配置（所有输出绑定生效） #

如果希望所有Kafka输出绑定都关闭Type headers，可以配置：

spring:
  cloud:
    stream:
      kafka:
        bindings:
          default:
            producer:
              configuration:
                spring.json.add.type.headers: false

方式3：自定义JsonSerializer Bean #

通过代码创建配置好的JsonSerializer实例，替代默认的序列化器：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.support.serializer.JsonSerializer;

@Configuration
public class KafkaSerializerConfig {

    @Bean
    public JsonSerializer<Object> jsonKeySerializer() {
        JsonSerializer<Object> serializer = new JsonSerializer<>();
        serializer.setAddTypeHeaders(false);
        return serializer;
    }

    @Bean
    public JsonSerializer<Object> jsonValueSerializer() {
        JsonSerializer<Object> serializer = new JsonSerializer<>();
        serializer.setAddTypeHeaders(false);
        return serializer;
    }
}

然后在配置中指定使用这些Bean（注意替换为你的实际包路径）：

spring:
  cloud:
    stream:
      kafka:
        binder:
          producerProperties:
            key.serializer: com.yourpackage.KafkaSerializerConfig#jsonKeySerializer
            value.serializer: com.yourpackage.KafkaSerializerConfig#jsonValueSerializer

额外检查点 #

• 确认没有其他配置类或代码手动创建JsonSerializer并设置addTypeHeaders=true，覆盖了你的配置。
• 检查版本兼容性：2.8版本的Spring Kafka对应Spring Cloud Stream Kafka binder的版本应为3.1.x左右，版本不匹配可能导致配置不生效。

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