Apache Kafka message binding

Contains information about the message representation in Apache Kafka.

Structure

copy

{

$schema:"http://json-schema.org/draft-07/schema#"

$id:"http://asyncapi.com/bindings/kafka/0.4.0/message.json"

title:"Message Schema"

type:"object"

additionalProperties:false

patternProperties:{...}

properties:{...}

examples:[...]

}

Examples

{
    "key": {
        "type": "string",
        "enum": [
            "myKey"
        ]
    },
    "schemaIdLocation": "payload",
    "schemaIdPayloadEncoding": "apicurio-new",
    "schemaLookupStrategy": "TopicIdStrategy",
    "bindingVersion": "0.4.0"
}

Migration guide

Changed

key

Key type was extended

{
    "key": {
        "anyOf": [ 
            { 
                "$ref": "http://asyncapi.com/definitions/3.0.0/Reference.json"
            }, 
            { 
                "$ref": "http://asyncapi.com/definitions/3.0.0/schema.json"
            }, 
            { 
                "$ref": "http://asyncapi.com/definitions/3.0.0/avroSchema_v1.json"
            } 
        ], 
        "description": "The message key."
    }
}