AvroSerializer class
Serializador avro que obtiene esquemas de un registro de esquema y no empaqueta esquemas en sus cargas.
Constructores
| Avro |
Crea un nuevo serializador. |
Métodos
| deserialize(MessageT, Deserialize |
Deserializa la carga del mensaje mediante el identificador de esquema en el campo de tipo de contenido si no se proporcionó ningún esquema. |
| serialize(unknown, string) | serializa el parámetro value según el esquema de entrada y crea un mensaje con los datos serializados. |
Detalles del constructor
AvroSerializer<MessageT>(SchemaRegistry, AvroSerializerOptions<MessageT>)
Crea un nuevo serializador.
new AvroSerializer(client: SchemaRegistry, options?: AvroSerializerOptions<MessageT>)Parámetros
- client
- SchemaRegistry
Registro de esquema donde se registran y obtienen esquemas. Normalmente se trata de una instancia schemaRegistryClient.
- options
-
AvroSerializerOptions<MessageT>
Detalles del método
deserialize(MessageT, DeserializeOptions)
Deserializa la carga del mensaje mediante el identificador de esquema en el campo de tipo de contenido si no se proporcionó ningún esquema.
function deserialize(message: MessageT, options?: DeserializeOptions): Promise<unknown>Parámetros
- message
-
MessageT
Mensaje con la carga que se va a deserializar.
- options
- DeserializeOptions
Opciones de descodificación.
Devoluciones
Promise<unknown>
Valor deserializado.
serialize(unknown, string)
serializa el parámetro value según el esquema de entrada y crea un mensaje con los datos serializados.
function serialize(value: unknown, schema: string): Promise<MessageT>Parámetros
- value
-
unknown
Valor que se va a serializar.
- schema
-
string
Esquema avro que se va a usar.
Devoluciones
Promise<MessageT>
Nuevo mensaje con el valor serializado. La estructura del mensaje se constscribe mediante la opción generador de mensajes.