Spring Boot 3.0.0中Kafka生产者值序列化配置失效求助

从异常信息来看，明明配置了JsonSerializer作为value序列化器，但实际运行时却使用了默认的StringSerializer，导致无法将SandwichOrder对象转为字符串抛出类型转换异常。以下是针对性的排查和解决步骤：

1. 确认Kafka Profile已正确激活 #

你的配置（无论是yml还是@Configuration类）都标注了kafka profile，如果启动时未激活该profile，所有Kafka相关的自定义配置都不会生效，Spring Boot会自动创建使用StringSerializer的默认KafkaTemplate。

解决方式：

• 启动应用时添加参数：--spring.profiles.active=kafka
• 或者在application.yml中默认激活profile：

  spring:
    profiles:
      active: kafka
  

• 也可以通过环境变量设置：SPRING_PROFILES_ACTIVE=kafka

2. 确保自定义KafkaTemplate被正确注入 #

如果项目中存在多个KafkaTemplate Bean（比如Spring Boot自动配置的默认Bean和你自定义的Bean），@Autowired可能会注入错误的实例（默认的String类型泛型的KafkaTemplate）。

解决方式：

• 给自定义的KafkaTemplate Bean指定名称：

  @Profile("kafka")
  @Configuration
  public class KafkaConfig {
  
      // ...其他Bean
  
      @Bean("sandwichOrderKafkaTemplate") // 指定Bean名称
      public KafkaTemplate<String, SandwichOrder> kafkaTemplate(ProducerFactory<String, SandwichOrder> producerFactory) {
          return new KafkaTemplate<>(producerFactory);
      }
  }
  

• 注入时通过@Qualifier指定对应的Bean：

  @Profile("kafka")
  @Service
  public class KafkaOrderMessagingService implements OrderMessagingService {
  
      private final KafkaTemplate<String, SandwichOrder> kafkaTemplate;
  
      // 用@Qualifier指定Bean名称
      public KafkaOrderMessagingService(@Qualifier("sandwichOrderKafkaTemplate") KafkaTemplate<String, SandwichOrder> kafkaTemplate) {
          this.kafkaTemplate = kafkaTemplate;
      }
  
      // ...其他方法
  }
  

3. 完善手动ProducerFactory配置 #

你的手动配置中缺少bootstrap-servers参数，虽然异常中显示bootstrap地址正确（可能来自自动配置），但为了配置的完整性，避免冲突，建议补充：

@Bean
public Map<String, Object> producerConfig() {
    Map<String, Object> props = new HashMap<>();
    props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092"); // 补充kafka地址
    props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
    props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class);
    props.put(JsonSerializer.ADD_TYPE_INFO_HEADERS, false); // 对应yml中的配置
    return props;
}

4. 检查Spring Kafka依赖版本 #

Spring Boot 3.0.x对应的Spring Kafka版本是3.0.x，确保依赖正确引入（无需指定版本，Spring Boot Starter会自动管理）：

<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
</dependency>

5. 验证SandwichOrder类的可序列化性 #

虽然JsonSerializer不需要类实现java.io.Serializable，但需要确保类有无参构造函数（Jackson序列化需要），同时字段要有getter方法：

public class SandwichOrder {
    // 无参构造函数
    public SandwichOrder() {}

    // 字段定义
    private Long id;
    private String name;
    // ...其他字段

    // getter和setter方法
    public Long getId() { return id; }
    public void setId(Long id) { this.id = id; }
    // ...其他getter/setter
}

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