AvroSerializer class
Avro 串行化程式會從架構登錄取得架構，而且不會將架構封裝到其承載中。
建構函式
| Avro |
建立新的串行化程式。 |
方法
| deserialize(MessageT, Deserialize |
如果未提供架構，請使用內容類型欄位中的架構識別碼還原串行化訊息的承載。 |
| serialize(unknown, string) | 根據輸入架構串行化 value 參數，並建立具有串行化數據的訊息。 |
建構函式詳細資料
AvroSerializer<MessageT>(SchemaRegistry, AvroSerializerOptions<MessageT>)
建立新的串行化程式。
new AvroSerializer(client: SchemaRegistry, options?: AvroSerializerOptions<MessageT>)參數
- client
- SchemaRegistry
註冊和取得架構的架構登錄。 這通常是 SchemaRegistryClient 實例。
- options
-
AvroSerializerOptions<MessageT>
方法詳細資料
deserialize(MessageT, DeserializeOptions)
如果未提供架構，請使用內容類型欄位中的架構識別碼還原串行化訊息的承載。
function deserialize(message: MessageT, options?: DeserializeOptions): Promise<unknown>參數
- message
-
MessageT
具有要還原串行化之承載的訊息。
- options
- DeserializeOptions
譯碼選項。
傳回
Promise<unknown>
還原串行化值。
serialize(unknown, string)
根據輸入架構串行化 value 參數，並建立具有串行化數據的訊息。
function serialize(value: unknown, schema: string): Promise<MessageT>參數
- value
-
unknown
要串行化的值。
- schema
-
string
要使用的 Avro 架構。
傳回
Promise<MessageT>
具有串行化值的新訊息。 訊息的結構是由訊息處理站選項所控制。