AvroSerializer class
Serializzatore Avro che ottiene gli schemi da un registro schemi e non inserisce gli schemi nei payload.
Costruttori
| Avro |
Crea un nuovo serializzatore. |
Metodi
| deserialize(MessageT, Deserialize |
Deserializza il payload del messaggio usando l'ID schema nel campo tipo di contenuto se non è stato specificato alcuno schema. |
| serialize(unknown, string) | serializza il parametro value in base allo schema di input e crea un messaggio con i dati serializzati. |
Dettagli costruttore
AvroSerializer<MessageT>(SchemaRegistry, AvroSerializerOptions<MessageT>)
Crea un nuovo serializzatore.
new AvroSerializer(client: SchemaRegistry, options?: AvroSerializerOptions<MessageT>)Parametri
- client
- SchemaRegistry
Registro schemi in cui vengono registrati e ottenuti gli schemi. In genere si tratta di un'istanza di SchemaRegistryClient.
- options
-
AvroSerializerOptions<MessageT>
Dettagli metodo
deserialize(MessageT, DeserializeOptions)
Deserializza il payload del messaggio usando l'ID schema nel campo tipo di contenuto se non è stato specificato alcuno schema.
function deserialize(message: MessageT, options?: DeserializeOptions): Promise<unknown>Parametri
- message
-
MessageT
Messaggio con il payload da deserializzare.
- options
- DeserializeOptions
Opzioni di decodifica.
Restituisce
Promise<unknown>
Valore deserializzato.
serialize(unknown, string)
serializza il parametro value in base allo schema di input e crea un messaggio con i dati serializzati.
function serialize(value: unknown, schema: string): Promise<MessageT>Parametri
- value
-
unknown
Valore da serializzare.
- schema
-
string
Schema Avro da usare.
Restituisce
Promise<MessageT>
Nuovo messaggio con il valore serializzato. La struttura del messaggio viene const rollback dall'opzione message factory.