AvroSerializer class
Avro Serializer, der Schemas aus einer Schemaregistrierung abruft und keine Schemas in seine Nutzlasten packt.
Konstruktoren
| Avro |
Erstellt einen neuen Serialisierer. |
Methoden
| deserialize(MessageT, Deserialize |
Deserialisiert die Nutzlast der Nachricht mithilfe der Schema-ID im Inhaltstypfeld, wenn kein Schema angegeben wurde. |
| serialize(unknown, string) | Serialisiert den Wertparameter gemäß dem Eingabeschema und erstellt eine Nachricht mit den serialisierten Daten. |
Details zum Konstruktor
AvroSerializer<MessageT>(SchemaRegistry, AvroSerializerOptions<MessageT>)
Erstellt einen neuen Serialisierer.
new AvroSerializer(client: SchemaRegistry, options?: AvroSerializerOptions<MessageT>)Parameter
- client
- SchemaRegistry
Schemaregistrierung, bei der Schemas registriert und abgerufen werden. In der Regel handelt es sich hierbei um eine SchemaRegistryClient-Instanz.
- options
-
AvroSerializerOptions<MessageT>
Details zur Methode
deserialize(MessageT, DeserializeOptions)
Deserialisiert die Nutzlast der Nachricht mithilfe der Schema-ID im Inhaltstypfeld, wenn kein Schema angegeben wurde.
function deserialize(message: MessageT, options?: DeserializeOptions): Promise<unknown>Parameter
- message
-
MessageT
Die Nachricht mit der Nutzlast, die deserialisiert werden soll.
- options
- DeserializeOptions
Decodierungsoptionen.
Gibt zurück
Promise<unknown>
Der deserialisierte Wert.
serialize(unknown, string)
Serialisiert den Wertparameter gemäß dem Eingabeschema und erstellt eine Nachricht mit den serialisierten Daten.
function serialize(value: unknown, schema: string): Promise<MessageT>Parameter
- value
-
unknown
Der zu serialisierende Wert.
- schema
-
string
Das zu verwendende Avro-Schema.
Gibt zurück
Promise<MessageT>
Eine neue Nachricht mit dem serialisierten Wert. Die Struktur der Nachricht wird durch die Option Message Factory zusammengerollt.