定义 Avro 模式

Question

我有一些这样的 avro 数据打印在终端中。

{"cust_status_id":0, "cust_status_description":{"string":" Approved"}}

我创建的 avro 模式是这样的

{
  "namespace": "com.thp.report.model",
  "type": "record",
  "name": "PraStatusMaster",
  "fields": [
    {
      "name": "cust_status_id",
      "type": "int"
    },
    {
      "name": "cust_status_description",
      "type": "string",
      "avro.java.string": "String"
    }
  ]
}

模式是否正确？

Answer 1

您 json 的正确架构如下：

{
  "name": "PraStatusMaster",
  "type": "record",
  "namespace": "com.thp.report.model",
  "fields": [
    {
      "name": "cust_status_id",
      "type": "int"
    },
    {
      "name": "cust_status_description",
      "type": {
        "name": "cust_status_description",
        "type": "record",
        "fields": [
          {
            "name": "string",
            "type": "string"
          }
        ]
      }
    }
  ]
}

定义 Avro 模式

Defining an Avro Schema

avro