AvroSerializer class
Serializador Avro que obtém esquemas de um registro de esquema e não empacota esquemas em suas cargas.
Construtores
| Avro |
Cria um novo serializador. |
Métodos
| deserialize(MessageT, Deserialize |
Desserializa o conteúdo da mensagem usando a ID do esquema no campo 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 em que os esquemas são registrados e obtidos. Normalmente, essa é uma instância schemaRegistryClient.
- options
-
AvroSerializerOptions<MessageT>
Detalhes do método
deserialize(MessageT, DeserializeOptions)
Desserializa o conteúdo da mensagem usando a ID do esquema no campo tipo de conteúdo se nenhum esquema foi fornecido.
function deserialize(message: MessageT, options?: DeserializeOptions): Promise<unknown>Parâmetros
- message
-
MessageT
A mensagem com o conteúdo a ser desserializado.
- options
- DeserializeOptions
Opções de decodificação.
Retornos
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.
Retornos
Promise<MessageT>
Uma nova mensagem com o valor serializado. A estrutura da mensagem é constrollada pela opção de fábrica de mensagens.