Java 中的 Avro 枚举序列化

Question

我正在尝试将枚举值序列化为 Avro 消息并发送它。该架构是用以下内容构建的：

Schema myschema = SchemaBuilder.record("com.testing.schemas").fields()
.name("enumTest").type().nullable().enumeration("aname")
.symbols("a","b","c","d","e").noDefault();

看起来像这样

{"name":"enumTest","type":
[{"type":"enum","name":"aname",
"symbols":"a","b","c","d","e"]}
,"null"]}

我的代码：

GenericRecord record = new GenericData.Record(myschema);
GenericData.EnumSymbol symbol = new GenericData.EnumSymbol(
myschema.getField("enumTest").schema(), "a");
record.put("enumTest", symbol);

当尝试发送消息时，我收到错误：

Error serializing Avro message
org.apache.avro.UnresolvedUnionException: Not in union [{"type":"enum","name":"aname","namespace":"com.testing.schemas","symbols":["a","b","c","d","e"]},"null"]: a

我缺少什么？谢谢。

Answer 1

字段的类型aname是 Union，而不是 Enum：

[ {
  "type" : "enum",
  "name" : "aname",
  "namespace" : "com.testing",
  "symbols" : [ "a", "b", "c", "d", "e" ]
}, "null" ]

你可以这样做：

    String namespace = "com.testing";

    Schema enumTest =
        SchemaBuilder.enumeration("aname")
            .namespace(namespace)
            .symbols("a", "b", "c", "d", "e");

    Schema myschema =
        SchemaBuilder.record("schemas")
            .namespace(namespace)
            .fields()
            .name("enumTest")
            .type()
            .unionOf()
            .nullType()
            .and()
            .type(enumTest)
            .endUnion()
            .noDefault()
            .endRecord();

    GenericRecord record = new GenericData.Record(myschema);
    GenericData.EnumSymbol symbol = new GenericData.EnumSymbol(enumTest, "a");
    record.put("enumTest", symbol);