{
  "@context": {
    "@version": 1.1,
    "aklivity": "https://www.aklivity.io/schema/",
    "schema": "https://schema.org/",
    "dcterms": "http://purl.org/dc/terms/",
    "xsd": "http://www.w3.org/2001/XMLSchema#",
    "kafka": "https://kafka.apache.org/schema/",

    "KafkaMessage": "aklivity:KafkaMessage",
    "KafkaTopic": "aklivity:KafkaTopic",

    "key": {
      "@id": "aklivity:messageKey",
      "@type": "xsd:string"
    },
    "value": {
      "@id": "aklivity:messageValue",
      "@type": "xsd:string"
    },
    "topic": {
      "@id": "kafka:topic",
      "@type": "xsd:string"
    },
    "partition": {
      "@id": "kafka:partition",
      "@type": "xsd:integer"
    },
    "offset": {
      "@id": "kafka:offset",
      "@type": "xsd:integer"
    },
    "timestamp": {
      "@id": "schema:dateCreated",
      "@type": "xsd:dateTime"
    },
    "headers": {
      "@id": "aklivity:headers",
      "@container": "@set"
    }
  }
}