@qualithm/kafka-client - v0.1.6
    Preparing search index...

    Type Alias Deserializer<T>

    Deserializes bytes back to a value of type T for consuming.

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

    Type Parameters

    • T
    Index

    Properties

    Properties

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

    Deserialize bytes to a value.

    Type Declaration

      • (data: Uint8Array, topic: string): T
      • Parameters

        • data: Uint8Array

          The bytes to deserialize.

        • topic: string

          The topic the message was consumed from (for topic-aware deserialization).

        Returns T

        The deserialized value.