Type Alias AsyncSerializer<T>

Async serializer for use with Schema Registry.

Network calls (schema registration, ID lookup) may be required during serialization.

type AsyncSerializer<T> = {
serialize: (value: T, topic: string) => Promise<Uint8Array>;
}

Type Parameters

T

Index

Properties

Properties

`Readonly`serialize

serialize: (value: T, topic: string) => Promise<Uint8Array>

Serialize a value to bytes, potentially fetching/registering schemas.

Type Declaration

- (value: T, topic: string): Promise<Uint8Array>
- Parameters
  - value: T
    The value to serialize.
  - topic: string
    The topic the message will be produced to.
  Returns Promise<Uint8Array>
  The serialized bytes including the Confluent wire format header.