使用 AVRO 编码可选字符串

如何解决使用 AVRO 编码可选字符串

我使用的是 Avro 1.10.2 版

我有以下架构，optionalField 作为可选的 JSON 字符串：

{
  "namespace": "foo.bar","name": "FooBar","type": "record","fields": [
    {
      "name": "optionalField","type": [
        "null","string"
      ]
    }
  ]
}

我使用 Avro Maven 插件来执行代码生成。

但是，当我使用以下代码对该对象的实例进行编码时：

FooBar fooBar = FooBar.newBuilder()
                .setoptionalField("value")
                .build();

Schema schema = fooBar.getSchema();
ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
Encoder jsonEncoder = EncoderFactory.get().jsonEncoder(schema,byteArrayOutputStream);
SpecificDatumWriter<Object> writer = new SpecificDatumWriter<>(schema);
writer.write(fooBar,jsonEncoder);
jsonEncoder.flush();

System.out.println(byteArrayOutputStream.toString());

输出为：

{"optionalField":{"string":"value"}}

而不是我所期望的：

{"optionalField":"value"}

据我所知，Avro specification 中的任何内容似乎都没有暗示只有记录可以是可选的。此外，在工会下：

如上所述，联合使用 JSON 数组表示。例如，["null","string"] 声明了一个可以是空值或字符串的模式。

我的理解是否正确，Avro 真的允许可选字符串字段吗？这是一个错误吗？我错过了什么？

解决方法

我的理解是否正确，Avro 真的允许可选字符串字段吗？

是的，Avro 支持 null 和 string 的联合

我错过了什么？

Avro JSON 编码器的工作方式与您预期的不同。如 https://avro.apache.org/docs/current/spec.html#json_encoding 中所述，联合使用类型信息编码为字典，而不仅仅是值。 Avro 票务跟踪器中有一个悬而未决的问题，要求您提供您正在寻找的格式，但尚未解决：https://issues.apache.org/jira/browse/AVRO-1582