AvroSerializer class
Сериализатор Avro, который получает схемы из реестра схем и не упаковывает схемы в полезные данные.
Конструкторы
| Avro |
Создает новый сериализатор. |
Методы
| deserialize(MessageT, Deserialize |
Десериализирует полезные данные сообщения с помощью идентификатора схемы в поле типа контента, если схема не была указана. |
| serialize(unknown, string) | сериализует параметр значения в соответствии с входной схемой и создает сообщение с сериализованными данными. |
Сведения о конструкторе
AvroSerializer<MessageT>(SchemaRegistry, AvroSerializerOptions<MessageT>)
Создает новый сериализатор.
new AvroSerializer(client: SchemaRegistry, options?: AvroSerializerOptions<MessageT>)Параметры
- client
- SchemaRegistry
Реестр схем, где регистрируются и получаются схемы. Обычно это экземпляр SchemaRegistryClient.
- options
-
AvroSerializerOptions<MessageT>
Сведения о методе
deserialize(MessageT, DeserializeOptions)
Десериализирует полезные данные сообщения с помощью идентификатора схемы в поле типа контента, если схема не была указана.
function deserialize(message: MessageT, options?: DeserializeOptions): Promise<unknown>Параметры
- message
-
MessageT
Сообщение с полезными данными для десериализации.
- options
- DeserializeOptions
Параметры декодирования.
Возвращаемое значение
Promise<unknown>
Десериализированное значение.
serialize(unknown, string)
сериализует параметр значения в соответствии с входной схемой и создает сообщение с сериализованными данными.
function serialize(value: unknown, schema: string): Promise<MessageT>Параметры
- value
-
unknown
Значение для сериализации.
- schema
-
string
Используемая схема Avro.
Возвращаемое значение
Promise<MessageT>
Новое сообщение с сериализованным значением. Структура сообщения константируется параметром фабрики сообщений.