Sdílet prostřednictvím


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

AvroSerializer<MessageT>(SchemaRegistry, AvroSerializerOptions<MessageT>)

Vytvoří nový serializátor.

Metody

deserialize(MessageT, DeserializeOptions)

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.