反序列化具有模式类型作为对象的 Avro 消息

Question

我正在阅读包含 Avro 消息的 Kafka 主题。我给出了以下架构。 我无法解析架构和反序列化消息。

{
  "type": "record",
  "name": "Request",
  "namespace": "com.sk.avro.model",
  "fields": [
    {
      "name": "empId",
      "type": [
        "null",
        "string"
      ],
      "default": null,
      "description": "REQUIRED "
    },
    {
      "name": "carUnit",
      "type": "com.example.CarUnit",
      "default": "ABC",
      "description": "Car id"
    }
  ]
}

我遇到以下错误：

The type of the "carUnit" field must be a defined name or a {"type": ...} expression

谁能帮帮忙。

Answer 1

怎么样

{
    "name": "businessUnit",
    "type": { 
        "type": { 
            "type": "record ", 
            "name": "BusinessUnit ", 
            "fields": [{ 
                "name": "hostName ", 
                "type": "string " 
             }] 
         } 
     } 
 }