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

    Function createProtobufSerde

    • Creates an async Protobuf serde with Schema Registry integration.

      Serialization: Encodes the value using the specified Protobuf message type and prepends the Confluent wire format header (magic byte + schema ID

      • message index array).

      Deserialization: Reads the schema ID and message index array from the wire format header, fetches the schema from the registry, and decodes the Protobuf binary payload.

      Type Parameters

      • T

      Parameters

      Returns AsyncSerde<T>

      Async serde that produces/consumes Confluent wire format messages.