AvroSerializer class
Avro 序列化程序从架构注册表获取架构,并且不会将架构打包到其有效负载中。
方法
| deserialize(MessageT, Deserialize |
如果未提供架构,则使用内容类型字段中的架构 ID 反序列化消息的有效负载。 |
| serialize(unknown, string) | 根据输入架构序列化值参数,并创建包含序列化数据的消息。 |
构造函数详细信息
AvroSerializer<MessageT>(SchemaRegistry, AvroSerializerOptions<MessageT>)
创建新的序列化程序。
new AvroSerializer(client: SchemaRegistry, options?: AvroSerializerOptions<MessageT>)
参数
- client
- SchemaRegistry
在其中注册和获取架构的架构注册表。 通常,这是 SchemaRegistryClient 实例。
- options
-
AvroSerializerOptions<MessageT>
方法详细信息
deserialize(MessageT, DeserializeOptions)
如果未提供架构,则使用内容类型字段中的架构 ID 反序列化消息的有效负载。
function deserialize(message: MessageT, options?: DeserializeOptions): Promise<unknown>
参数
- message
-
MessageT
包含要反序列化的有效负载的消息。
- options
- DeserializeOptions
解码选项。
返回
Promise<unknown>
反序列化的值。
serialize(unknown, string)
根据输入架构序列化值参数,并创建包含序列化数据的消息。
function serialize(value: unknown, schema: string): Promise<MessageT>
参数
- value
-
unknown
要序列化的值。
- schema
-
string
要使用的 Avro 架构。
返回
Promise<MessageT>
包含序列化值的新消息。 消息结构由消息工厂选项控制。