反序列化模式类型为object的avro消息

yzuktlbb  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(322)

我在读Kafka的一个主题,里面有avro的信息。我已经给出了下面的模式。我无法分析架构并反序列化消息。

{
  "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

有人能帮忙吗。

vlju58qv

vlju58qv1#

怎么样

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

相关问题