AvroSerializer class
Serializátor Avro, který získává schémata z registru schématu a nezabaluje schémata do svých datových částí.
Konstruktory
Avro |
Vytvoří nový serializátor. |
Metody
deserialize(MessageT, Deserialize |
Deserializuje datovou část zprávy pomocí ID schématu v poli typu obsahu, pokud nebylo zadáno žádné schéma. |
serialize(unknown, string) | serializuje parametr hodnoty podle vstupního schématu a vytvoří zprávu se serializovanými daty. |
Podrobnosti konstruktoru
AvroSerializer<MessageT>(SchemaRegistry, AvroSerializerOptions<MessageT>)
Vytvoří nový serializátor.
new AvroSerializer(client: SchemaRegistry, options?: AvroSerializerOptions<MessageT>)
Parametry
- client
- SchemaRegistry
Registr schématu, ve kterém jsou schémata registrována a získána. Obvykle se jedná o instanci SchemaRegistryClient.
- options
-
AvroSerializerOptions<MessageT>
Podrobnosti metody
deserialize(MessageT, DeserializeOptions)
Deserializuje datovou část zprávy pomocí ID schématu v poli typu obsahu, pokud nebylo zadáno žádné schéma.
function deserialize(message: MessageT, options?: DeserializeOptions): Promise<unknown>
Parametry
- message
-
MessageT
Zpráva s datovou částí, která má být deserializována.
- options
- DeserializeOptions
Možnosti dekódování.
Návraty
Promise<unknown>
Deserializovaná hodnota.
serialize(unknown, string)
serializuje parametr hodnoty podle vstupního schématu a vytvoří zprávu se serializovanými daty.
function serialize(value: unknown, schema: string): Promise<MessageT>
Parametry
- value
-
unknown
Hodnota k serializaci.
- schema
-
string
Schéma Avro, které se má použít.
Návraty
Promise<MessageT>
Nová zpráva se serializovanou hodnotou. Struktura zprávy je zahlcená možností objektu pro vytváření zpráv.