第 56 章 Avro Jackson
jackson Avro 是一个数据格式,它使用带 Avro 扩展的 Jackson 库 将 Avro 有效负载合并到 Java 对象中或将 Java 对象合并到 Avro 有效负载中。
注意
如果您熟悉 Jackson,则此 Avro 数据格式的行为方式与其 JSON 对应部分相同,因此可用于注解 JSON 序列化/反序列化的类。
from("kafka:topic"). unmarshal().avro(AvroLibrary.Jackson, JsonNode.class). to("log:info");
56.1. 配置 SchemaResolver
由于 Avro 序列化基于 schema,因此此数据格式需要您提供一个 SchemaResolver 对象,该对象能够查找将要被归档/解放的每个交换的 schema。
您可以向 registry 添加单个 SchemaResolver,它将被自动查找。或者,您可以明确指定对自定义 SchemaResolver 的引用。