Type Alias AsyncDeserializer<T>

Async deserializer for use with Schema Registry.

Network calls (schema fetch by ID) may be required during deserialization when encountering a previously unseen schema ID.

type AsyncDeserializer<T> = {
deserialize: (data: Uint8Array, topic: string) => Promise<T>;
}

Type Parameters

T

Index

Properties

Properties

`Readonly`deserialize

deserialize: (data: Uint8Array, topic: string) => Promise<T>

Deserialize bytes to a value, potentially fetching schemas.

Type Declaration

- (data: Uint8Array, topic: string): Promise<T>
- Parameters
  - data: Uint8Array
    The bytes to deserialize (including Confluent wire format header).
  - topic: string
    The topic the message was consumed from.
  Returns Promise<T>
  The deserialized value.