Spring Boot集成Kafka发送消息遇SerializationException问题求助

问题重现 #

新增JSON插入微服务并修改实体后，调用接口发送Kafka消息时抛出：

org.apache.kafka.common.errors.SerializationException: Can't serialize data [com.example.usercreate.dto.AddressUserDto@558d6cd1] for topic [quickstart-events]

以下是针对性排查步骤：

1. 核对Kafka生产者序列化配置 #

确认application.properties中生产者的value序列化器是否配置为JSON类型，而非默认的字符串/字节数组序列化器。如果之前发送的是简单类型，新增DTO后未更新配置会直接触发序列化失败。
正确配置示例：

spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.springframework.kafka.support.serializer.JsonSerializer
# 可选：指定可信包路径，避免类型校验报错
spring.kafka.producer.properties.spring.json.trusted.packages=com.example.usercreate.dto

2. 检查AddressUserDto的序列化合规性 #

• 必须提供无参构造函数：JSON序列化器（如Jackson）依赖无参构造实例化对象，新增字段后如果移除或未添加无参构造，会直接导致序列化失败。
• 确保所有需要序列化的字段都有公开的getter方法：序列化器需要通过getter读取字段值，私有字段无getter会被判定为无可用序列化属性。
• 避免用transient修饰需要序列化的字段：该关键字会让序列化器忽略对应字段，若业务需要序列化则不能使用。

3. 验证ModelMapper的映射有效性 #

在发送Kafka消息前，先打印映射后的DTO对象，确认字段赋值正常，甚至可以提前用Jackson转JSON测试：

AddressUserDto mappedDto = modelMapper.map(yourEntity, AddressUserDto.class);
// 提前验证序列化可行性
ObjectMapper mapper = new ObjectMapper();
System.out.println(mapper.writeValueAsString(mappedDto));

如果这一步抛出JSON序列化异常，说明问题出在DTO本身而非Kafka配置，直接定位DTO的结构问题即可。

4. 确认依赖版本兼容性 #

检查spring-kafka依赖版本与Spring Boot版本是否匹配：

• Spring Boot 2.x 对应 spring-kafka 2.x 系列
• Spring Boot 3.x 对应 spring-kafka 3.x 系列
  版本不兼容会导致底层序列化逻辑出现未预期的异常。

5. 查看完整异常栈信息 #

顶层异常仅提示序列化失败，完整栈信息中的Caused by部分会给出具体原因：
比如出现InvalidDefinitionException说明无参构造或getter缺失；JsonMappingException可能是字段类型不兼容。通过完整栈信息可以快速定位核心问题。

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