AvroSerializer class
Serializador Avro que obtém esquemas de um registro de esquema e não empacota esquemas em suas cargas úteis.
Construtores
| Avro |
Cria um novo serializador. |
Métodos
| deserialize(MessageT, Deserialize |
Desserializa a carga da mensagem usando a ID do esquema no campo de tipo de conteúdo se nenhum esquema foi fornecido. |
| serialize(unknown, string) | serializa o parâmetro value de acordo com o esquema de entrada e cria uma mensagem com os dados serializados. |
Detalhes do Construtor
AvroSerializer<MessageT>(SchemaRegistry, AvroSerializerOptions<MessageT>)
Cria um novo serializador.
new AvroSerializer(client: SchemaRegistry, options?: AvroSerializerOptions<MessageT>)Parâmetros
- client
- SchemaRegistry
Registro de esquema onde os esquemas são registrados e obtidos. Normalmente, esta é uma instância SchemaRegistryClient.
- options
-
AvroSerializerOptions<MessageT>
Detalhes de Método
deserialize(MessageT, DeserializeOptions)
Desserializa a carga da mensagem usando a ID do esquema no campo de tipo de conteúdo se nenhum esquema foi fornecido.
function deserialize(message: MessageT, options?: DeserializeOptions): Promise<unknown>Parâmetros
- message
-
MessageT
A mensagem com a carga a ser desserializada.
- options
- DeserializeOptions
Opções de descodificação.
Devoluções
Promise<unknown>
O valor desserializado.
serialize(unknown, string)
serializa o parâmetro value de acordo com o esquema de entrada e cria uma mensagem com os dados serializados.
function serialize(value: unknown, schema: string): Promise<MessageT>Parâmetros
- value
-
unknown
O valor a ser serializado.
- schema
-
string
O esquema Avro a ser usado.
Devoluções
Promise<MessageT>
Uma nova mensagem com o valor serializado. A estrutura da mensagem é restringida pela opção de fábrica de mensagens.