AvroSerializer class
Serializador Avro que obtém esquemas de um registo de esquema e não empacota esquemas nos respetivos payloads.
Construtores
| Avro |
Cria um novo serializador. |
Métodos
| deserialize(MessageT, Deserialize |
Anular a serialização do payload da mensagem com o ID de esquema no campo de tipo de conteúdo se não tiver sido fornecido nenhum esquema. |
| serialize(unknown, string) | serializa o parâmetro de valor 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
Registo de Esquema onde os esquemas são registados e obtidos. Normalmente, esta é uma instância SchemaRegistryClient.
- options
-
AvroSerializerOptions<MessageT>
Detalhes de Método
deserialize(MessageT, DeserializeOptions)
Anular a serialização do payload da mensagem com o ID de esquema no campo de tipo de conteúdo se não tiver sido fornecido nenhum esquema.
function deserialize(message: MessageT, options?: DeserializeOptions): Promise<unknown>Parâmetros
- message
-
MessageT
A mensagem com o payload a anular a serialização.
- options
- DeserializeOptions
Opções de descodificação.
Devoluções
Promise<unknown>
O valor serializado anular a serialização.
serialize(unknown, string)
serializa o parâmetro de valor 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 serializar.
- schema
-
string
O esquema Avro a utilizar.
Devoluções
Promise<MessageT>
Uma nova mensagem com o valor serializado. A estrutura da mensagem é registada pela opção de fábrica de mensagens.