AvroSerializer class
Sérialiseur Avro qui obtient des schémas à partir d’un registre de schémas et n’empaquet pas de schémas dans ses charges utiles.
Constructeurs
| Avro |
Crée un sérialiseur. |
Méthodes
| deserialize(MessageT, Deserialize |
Désérialise la charge utile du message à l’aide de l’ID de schéma dans le champ de type de contenu si aucun schéma n’a été fourni. |
| serialize(unknown, string) | sérialise le paramètre value en fonction du schéma d’entrée et crée un message avec les données sérialisées. |
Détails du constructeur
AvroSerializer<MessageT>(SchemaRegistry, AvroSerializerOptions<MessageT>)
Crée un sérialiseur.
new AvroSerializer(client: SchemaRegistry, options?: AvroSerializerOptions<MessageT>)Paramètres
- client
- SchemaRegistry
Registre de schémas où les schémas sont inscrits et obtenus. Il s’agit généralement d’une instance SchemaRegistryClient.
- options
-
AvroSerializerOptions<MessageT>
Détails de la méthode
deserialize(MessageT, DeserializeOptions)
Désérialise la charge utile du message à l’aide de l’ID de schéma dans le champ de type de contenu si aucun schéma n’a été fourni.
function deserialize(message: MessageT, options?: DeserializeOptions): Promise<unknown>Paramètres
- message
-
MessageT
Message avec la charge utile à désérialiser.
- options
- DeserializeOptions
Options de décodage.
Retours
Promise<unknown>
Valeur désérialisée.
serialize(unknown, string)
sérialise le paramètre value en fonction du schéma d’entrée et crée un message avec les données sérialisées.
function serialize(value: unknown, schema: string): Promise<MessageT>Paramètres
- value
-
unknown
Valeur à sérialiser.
- schema
-
string
Schéma Avro à utiliser.
Retours
Promise<MessageT>
Nouveau message avec la valeur sérialisée. La structure du message est constrolled par l’option de fabrique de messages.