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

    Function decodeWireFormatHeader

    • Decode a Confluent wire format header.

      Parameters

      • data: Uint8Array

        Message bytes (must be at least 5 bytes).

      Returns { offset: number; schemaId: number }

      The schema ID from the header.

      If the magic byte is invalid or data is too short.