AvroSerializer class
스키마 레지스트리에서 스키마를 가져오고 스키마를 페이로드에 압축하지 않는 Avro 직렬 변환기입니다.
생성자
| Avro |
새 직렬 변환기를 만듭니다. |
메서드
| deserialize(MessageT, Deserialize |
스키마가 제공되지 않은 경우 콘텐츠 형식 필드에서 스키마 ID를 사용하여 메시지의 페이로드를 역직렬화합니다. |
| serialize(unknown, string) | 입력 스키마에 따라 값 매개 변수를 serialize하고 직렬화된 데이터를 사용하여 메시지를 만듭니다. |
생성자 세부 정보
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)
입력 스키마에 따라 값 매개 변수를 serialize하고 직렬화된 데이터를 사용하여 메시지를 만듭니다.
function serialize(value: unknown, schema: string): Promise<MessageT>매개 변수
- value
-
unknown
직렬화할 값입니다.
- schema
-
string
사용할 Avro 스키마입니다.
반환
Promise<MessageT>
직렬화된 값이 있는 새 메시지입니다. 메시지 구조는 메시지 팩터리 옵션에 의해 제어됩니다.