Added support for JSON Schema

InventoryAdjusted uses Avro but now also supports JSON Draft 7.

// labeled-line-markers.jsx
{
  "$schema": "http://json-schema.org/draft-07/schema#",
  "type": "object",
  "title": "Employee",
  "properties": {
    "Name": {
      "type": "string"
    },
    "Age": {
      "type": "integer"
    },
    "Town": {
      "type": "string"
    }
  },
  "required": ["Name", "Age", "Town"]
}

Using it with our Kafka Cluster

1. Create a new topic

# Create a topic named 'employee_topic'
kafka-topics.sh --create --topic employee_topic --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1

Step 2: Prepare the JSON Message

Create a JSON file named employee.json with the following content:

{
  "Name": "John Doe",
  "Age": 30,
  "Town": "Springfield"
}

Step 3: Produce the Message to Kafka Topic

Use the Kafka producer CLI to send the JSON message:

cat employee.json | kafka-console-producer.sh --topic employee_topic --bootstrap-server localhost:9092

Step 4: Verify the Message (Optional)

kafka-console-consumer.sh --topic employee_topic --from-beginning --bootstrap-server localhost:9092

Added new field to schema

We added the new town property to the schema for downstream consumers.

// labeled-line-markers.jsx
{
  "type" : "record",
  "namespace" : "Tutorialspoint",
  "name" : "Employee",
  "fields" : [
     { "name" : "Name" , "type" : "string" },
     { "name" : "Age" , "type" : "int" },

     { "name" : "Town" , "type" : "string" },
  ]
}

Removed fields from schema, added new owners

Gender property has been removed from the Schema of the event

Also added the full stackers team as owners of this event

{
  "type" : "record",
  "namespace" : "Tutorialspoint",
  "name" : "Employee",
  "fields" : [
    { "name" : "Name" , "type" : "string" },
    { "name" : "Age" , "type" : "int" },
    { "name" : "Gender" , "type" : "string" },
  ]
}