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

    Function createAvroSerde

    • Creates an async Avro serde with Schema Registry integration.

      Serialization: Encodes the value using the writer schema and prepends the Confluent wire format header (magic byte + schema ID). On first call, registers the schema if autoRegister is true.

      Deserialization: Reads the schema ID from the wire format header, fetches the schema from the registry (cached after first fetch), and decodes the Avro binary payload.

      Type Parameters

      • T

      Parameters

      Returns AsyncSerde<T>

      Async serde that produces/consumes Confluent wire format messages.