AvroSerializer class

Şemaları bir şema kayıt defterinden edinen ve yüklerine şema paketlemeyen Avro seri hale getiricisi.

Oluşturucular

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

Yeni bir seri hale getirici oluşturur.

Yöntemler

deserialize(MessageT, DeserializeOptions)

Şema sağlanmadıysa, içerik türü alanındaki şema kimliğini kullanarak iletinin yükünü seri durumdan çıkartır.

serialize(unknown, string)

giriş şemasına göre değer parametresini serileştirir ve serileştirilmiş verilerle bir ileti oluşturur.

Oluşturucu Ayrıntıları

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

Yeni bir seri hale getirici oluşturur.

new AvroSerializer(client: SchemaRegistry, options?: AvroSerializerOptions<MessageT>)

Parametreler

client
SchemaRegistry

Şemaların kaydedildiği ve alındığı Şema Kayıt Defteri. Genellikle bu bir SchemaRegistryClient örneğidir.

options

AvroSerializerOptions<MessageT>

Yöntem Ayrıntıları

deserialize(MessageT, DeserializeOptions)

Şema sağlanmadıysa, içerik türü alanındaki şema kimliğini kullanarak iletinin yükünü seri durumdan çıkartır.

function deserialize(message: MessageT, options?: DeserializeOptions): Promise<unknown>

Parametreler

message

MessageT

Seri durumdan çıkarılacak yükü içeren ileti.

options
DeserializeOptions

Kod çözme seçenekleri.

Döndürülenler

Promise<unknown>

Seri durumdan çıkarılmış değer.

serialize(unknown, string)

giriş şemasına göre değer parametresini serileştirir ve serileştirilmiş verilerle bir ileti oluşturur.

function serialize(value: unknown, schema: string): Promise<MessageT>

Parametreler

value

unknown

Serileştirecek değer.

schema

string

Kullanılacak Avro şeması.

Döndürülenler

Promise<MessageT>

Serileştirilmiş değere sahip yeni bir ileti. İletinin yapısı, ileti fabrikası seçeneği tarafından constrolled.