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