Kafka注册的Avro Schema数组联合类型输出异常问题

你的问题出在Avro联合类型的JSON序列化规则上：当联合类型的元素顺序是["null", "array"]时，非null的array属于联合中的第二个类型，Avro的JSON序列化会用类型名称作为键包装该值，以此明确当前使用的是联合中的哪一种类型。而去掉null联合后，类型是单一的array，自然直接输出数组。

解决方案1：调整联合类型的顺序 #

把array类型放在联合的第一个位置，null放在第二个，同时保留default: null。这样序列化数组时，因为它是联合的第一个类型，会直接输出数组；序列化null时则输出null，完全符合预期。

修改后的Schema：

{
  "doc": "list of employees",
  "name": "employees",
  "type": [
    {
      "type": "array",
      "items": {
        "avro.java.string": "String",
        "type": "string"
      }
    },
    "null"
  ],
  "default": null
}

解决方案2：调整客户端序列化配置 #

如果无法修改已注册的Schema（Schema注册后通常不可修改），可以检查你使用的Avro客户端序列化器配置，是否有参数可以禁用联合类型的包装行为。比如Java的Avro库中，可通过配置JsonEncoder的参数实现：

// 创建JsonEncoder时禁用类型包装
JsonEncoder encoder = EncoderFactory.get().jsonEncoder(schema, outputStream, true);
GenericDatumWriter<Object> writer = new GenericDatumWriter<>(schema);
writer.write(data, encoder);
encoder.flush();

注意：若Schema已在Registry中注册，调整顺序会视为新Schema，需重新注册并更新生产者/消费者的Schema引用。

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