AvroSerializer class
Avro serializer die schema's verkrijgt uit een schemaregister en geen schema's inpakt in de nettoladingen.
Constructors
| Avro |
Hiermee maakt u een nieuwe serialisatiefunctie. |
Methoden
| deserialize(MessageT, Deserialize |
Deserialisatie van de nettolading van het bericht met behulp van de schema-id in het inhoudstypeveld als er geen schema is opgegeven. |
| serialize(unknown, string) | serialiseert de waardeparameter volgens het invoerschema en maakt een bericht met de geserialiseerde gegevens. |
Constructordetails
AvroSerializer<MessageT>(SchemaRegistry, AvroSerializerOptions<MessageT>)
Hiermee maakt u een nieuwe serialisatiefunctie.
new AvroSerializer(client: SchemaRegistry, options?: AvroSerializerOptions<MessageT>)Parameters
- client
- SchemaRegistry
Schemaregister waarin schema's worden geregistreerd en verkregen. Dit is meestal een SchemaRegistryClient-exemplaar.
- options
-
AvroSerializerOptions<MessageT>
Methodedetails
deserialize(MessageT, DeserializeOptions)
Deserialisatie van de nettolading van het bericht met behulp van de schema-id in het inhoudstypeveld als er geen schema is opgegeven.
function deserialize(message: MessageT, options?: DeserializeOptions): Promise<unknown>Parameters
- message
-
MessageT
Het bericht met de nettolading die moet worden gedeserialiseerd.
- options
- DeserializeOptions
Decoderingsopties.
Retouren
Promise<unknown>
De gedeserialiseerde waarde.
serialize(unknown, string)
serialiseert de waardeparameter volgens het invoerschema en maakt een bericht met de geserialiseerde gegevens.
function serialize(value: unknown, schema: string): Promise<MessageT>Parameters
- value
-
unknown
De waarde die moet worden geserialiseerd.
- schema
-
string
Het Avro-schema dat moet worden gebruikt.
Retouren
Promise<MessageT>
Een nieuw bericht met de geserialiseerde waarde. De structuur van het bericht wordt ingeschreven door de optie berichtfactory.