Using Schema Registry

[magic byte 0x00][4-byte schema id][avro payload]

schema-registry-start etc/schema-registry/schema-registry.properties

props.put("value.serializer",
  "io.confluent.kafka.serializers.KafkaAvroSerializer");
props.put("schema.registry.url", "http://localhost:8081");

curl -X POST -H "Content-Type: application/vnd.schemaregistry.v1+json" \
  --data '{"schema":"{\"type\":\"string\"}"}' \
  http://localhost:8081/subjects/orders-value/versions

curl http://localhost:8081/subjects/orders-value/versions/latest

curl http://localhost:8081/subjects

curl -X DELETE http://localhost:8081/subjects/orders-value/versions/1

curl -X PUT -H "Content-Type: application/vnd.schemaregistry.v1+json" \
  --data '{"compatibility":"FULL"}' \
  http://localhost:8081/config/orders-value

curl -X POST -H "Content-Type: application/vnd.schemaregistry.v1+json" \
  --data @new-schema.json \
  http://localhost:8081/compatibility/subjects/orders-value/versions/latest

for s in $(curl -s http://localhost:8081/subjects | jq -r '.[]'); do
  curl -s http://localhost:8081/subjects/$s/versions/latest > "$s.json"
done