次の方法で共有


AvroSerializer class

スキーマ レジストリからスキーマを取得し、そのペイロードにスキーマをパックしない Avro シリアライザー。

コンストラクター

AvroSerializer<MessageT>(SchemaRegistry, AvroSerializerOptions<MessageT>)

新しいシリアライザーを作成します。

メソッド

deserialize(MessageT, DeserializeOptions)

スキーマが指定されていない場合は、コンテンツ タイプ フィールドのスキーマ 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>

シリアル化された値を持つ新しいメッセージ。 メッセージの構造は、メッセージ ファクトリ オプションによって制約されます。