第 54 章 Avro Jackson
Jackson Avro 是一个 Data Format,它使用 Jackson 库与 Avro 扩展名 将 Avro 有效负载解除 Java 对象,或组合 Java 对象到 Avro 有效负载中。
注意
如果您熟悉 Jackson,这个 Avro 数据格式的行为与其 JSON 计数器部分相同,因此可和注解为 JSON 序列化/反序列化/反序列化的类一起使用。
from("kafka:topic"). unmarshal().avro(AvroLibrary.Jackson, JsonNode.class). to("log:info");
54.1. 配置 SchemaResolver
由于 Avro 序列化基于架构,因此这种数据格式需要您提供一个 SchemaResolver 对象,它能够查找将要放入/unmarshalled/unmarshalled 的每个交换的 schema。
您可以将单个 SchemaResolver 添加到 registry,它会被自动查找。或者,您可以显式指定对自定义 SchemaResolver 的引用。