Package org.mockserver.async.serde

package org.mockserver.async.serde
  • Classes
    Class
    Description
    AvroPayloadCodec
    Converts message payloads between JSON text and Avro binary using Apache Avro's GenericDatum reader/writer — no code generation and no Confluent serde stack required.
    ConfluentWireFormat
    Encoder/decoder for the Confluent Schema Registry wire format used by Kafka Avro/Protobuf messages.
    ConfluentWireFormat.Decoded
    The result of decoding a wire-format message: the embedded schema id and the remaining serialized payload bytes.
    SchemaRegistryClient
    A minimal client for the Confluent Schema Registry REST API — just the two operations MockServer needs, implemented over the JDK's HttpClient so no Confluent Community License artifacts are pulled in: SchemaRegistryClient.getSchemaById(int) — GET /schemas/ids/{id}, used on the consume/verify path to resolve the schema embedded in a Confluent wire-format message. SchemaRegistryClient.register(String, String) — POST /subjects/{subject}/versions, used on the publish path to obtain the schema id to frame messages with.