第 76 章 protobuf Jackson
jackson Protobuf 是一个数据格式,它使用带有 Protobuf 扩展的 Jackson 库 将 Protobuf 有效负载 unmarshal a Protobuf 有效负载到 Protobuf 有效负载。
注意
如果您熟悉 Jackson,则此 Protobuf 数据格式的行为与其 JSON 对应部分相同,因此可用于注解用于 JSON 序列化/反序列化的类。
from("kafka:topic"). unmarshal().protobuf(ProtobufLibrary.Jackson, JsonNode.class). to("log:info");
76.1. 配置 SchemaResolver
由于 Protobuf 序列化是基于架构的,因此这些数据格式要求您提供一个 SchemaResolver 对象,该对象可以查找每个交换的模式,该交换将被完全使用/全部关闭。
您可以将单个 SchemaResolver 添加到 registry 中,它将自动查找。或者,您可以明确指定对自定义 SchemaResolver 的引用。