Skip to content

Apache Kafka message binding

Contains information about the message representation in Apache Kafka.

Structure

copy

Examples

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

Migration guide

Changed

key

Key type was extended

json
{
    "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."
    }
}