如何将嵌套Generic Record转换为JSON或POJO 及Avro对象REST响应处理

以下方案均无需提前导入Schema、也无需生成Specific Record类：

方案1：转标准JSON后反序列化为POJO #

• 依赖引入：添加jackson-dataformat-avro到项目依赖中
• 转换逻辑：直接从消费到的GenericRecord实例中获取运行时Schema，通过Avro格式的ObjectMapper完成序列化：

// 获取收到的Avro消息自带的Schema
Schema avroSchema = consumedGenericRecord.getSchema();
// 初始化支持Avro序列化的Jackson Mapper
ObjectMapper avroMapper = new AvroMapper();
// 序列化为标准JSON字符串
String standardJson = avroMapper.writerFor(GenericRecord.class)
                                .with(avroSchema)
                                .writeValueAsString(consumedGenericRecord);
// 用普通Jackson Mapper即可将上述JSON反序列化为自定义POJO
YourCustomPojo pojo = new ObjectMapper().readValue(standardJson, YourCustomPojo.class);

• 嵌套结构支持：原生支持多层嵌套的Generic Record、数组、Union等Avro类型，只要JSON字段和POJO字段名对应即可正常转换。

方案2：直接转换为自定义POJO #

省略转JSON字符串的中间步骤，直接完成类型映射：

Schema avroSchema = consumedGenericRecord.getSchema();
ObjectMapper avroMapper = new AvroMapper();
// 直接映射为自定义POJO，无需依赖Avro自动生成的类
YourCustomPojo pojo = avroMapper.readerFor(YourCustomPojo.class)
                                .with(avroSchema)
                                .readValue(avroMapper.writeValueAsBytes(consumedGenericRecord));

两种常用实现方案：

• 方案1：直接序列化Avro对象为JSON返回
  注册AvroModule到REST框架的全局ObjectMapper中，框架会自动完成Avro Specific Record的JSON序列化，无需手动转换。以Spring Boot为例：

@Bean
public ObjectMapper globalObjectMapper() {
    ObjectMapper mapper = new ObjectMapper();
    // 注册Avro类型支持模块
    mapper.registerModule(new AvroModule());
    // 可选配置：过滤null字段，避免响应中出现多余的null值
    mapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);
    return mapper;
}

配置完成后，Controller接口可直接返回Avro自动生成的类实例：

@GetMapping("/user")
public ResponseEntity<AutoGeneratedAvroUser> getUserInfo() {
    AutoGeneratedAvroUser user = // 从业务逻辑获取Avro对象
    return ResponseEntity.ok(user);
}

• 方案2：转换为自定义POJO后返回
  如果需要对外隐藏Avro生成类的内部结构，可沿用上述Generic Record转POJO的逻辑完成转换后再返回，Avro自动生成的SpecificRecord类本身实现了GenericRecord接口，可直接复用转换代码。

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