AvroSerializer class
スキーマ レジストリからスキーマを取得し、そのペイロードにスキーマをパックしない Avro シリアライザー。
コンストラクター
Avro |
新しいシリアライザーを作成します。 |
メソッド
deserialize(MessageT, Deserialize |
スキーマが指定されていない場合は、コンテンツ タイプ フィールドのスキーマ ID を使用してメッセージのペイロードを逆シリアル化します。 |
serialize(unknown, string) | は、入力スキーマに従って value パラメーターをシリアル化し、シリアル化されたデータを含むメッセージを作成します。 |
コンストラクターの詳細
AvroSerializer<MessageT>(SchemaRegistry, AvroSerializerOptions<MessageT>)
新しいシリアライザーを作成します。
new AvroSerializer(client: SchemaRegistry, options?: AvroSerializerOptions<MessageT>)
パラメーター
- client
- SchemaRegistry
スキーマが登録され、取得されるスキーマ レジストリ。 通常、これは SchemaRegistryClient インスタンスです。
- options
-
AvroSerializerOptions<MessageT>
メソッドの詳細
deserialize(MessageT, DeserializeOptions)
スキーマが指定されていない場合は、コンテンツ タイプ フィールドのスキーマ ID を使用してメッセージのペイロードを逆シリアル化します。
function deserialize(message: MessageT, options?: DeserializeOptions): Promise<unknown>
パラメーター
- message
-
MessageT
逆シリアル化するペイロードを含むメッセージ。
- options
- DeserializeOptions
デコード オプション。
戻り値
Promise<unknown>
逆シリアル化された値。
serialize(unknown, string)
は、入力スキーマに従って value パラメーターをシリアル化し、シリアル化されたデータを含むメッセージを作成します。
function serialize(value: unknown, schema: string): Promise<MessageT>
パラメーター
- value
-
unknown
シリアル化する値。
- schema
-
string
使用する Avro スキーマ。
戻り値
Promise<MessageT>
シリアル化された値を持つ新しいメッセージ。 メッセージの構造は、メッセージ ファクトリ オプションによって制約されます。