AvroSerializer class
Avro-serialiserare som hämtar scheman från ett schemaregister och inte packar scheman i sina nyttolaster.
Konstruktorer
| Avro |
Skapar en ny serialiserare. |
Metoder
| deserialize(MessageT, Deserialize |
Deserialiserar nyttolasten för meddelandet med hjälp av schema-ID:t i innehållstypfältet om inget schema angavs. |
| serialize(unknown, string) | serialiserar värdeparametern enligt indataschemat och skapar ett meddelande med serialiserade data. |
Konstruktorinformation
AvroSerializer<MessageT>(SchemaRegistry, AvroSerializerOptions<MessageT>)
Skapar en ny serialiserare.
new AvroSerializer(client: SchemaRegistry, options?: AvroSerializerOptions<MessageT>)
Parametrar
- client
- SchemaRegistry
Schemaregister där scheman registreras och hämtas. Detta är vanligtvis en SchemaRegistryClient-instans.
- options
-
AvroSerializerOptions<MessageT>
Metodinformation
deserialize(MessageT, DeserializeOptions)
Deserialiserar nyttolasten för meddelandet med hjälp av schema-ID:t i innehållstypfältet om inget schema angavs.
function deserialize(message: MessageT, options?: DeserializeOptions): Promise<unknown>
Parametrar
- message
-
MessageT
Meddelandet med nyttolasten som ska deserialiseras.
- options
- DeserializeOptions
Avkodningsalternativ.
Returer
Promise<unknown>
Det deserialiserade värdet.
serialize(unknown, string)
serialiserar värdeparametern enligt indataschemat och skapar ett meddelande med serialiserade data.
function serialize(value: unknown, schema: string): Promise<MessageT>
Parametrar
- value
-
unknown
Värdet som ska serialiseras.
- schema
-
string
Avro-schemat som ska användas.
Returer
Promise<MessageT>
Ett nytt meddelande med det serialiserade värdet. Strukturen för meddelandet är förkontrollad av alternativet meddelandefabrik.