Apache Kafka channel binding

Contains information about the message representation in Apache Kafka.

Structure

copy

Examples

{
    "topic": "my-specific-topic",
    "partitions": 20,
    "replicas": 3,
    "bindingVersion": "0.4.0"
}

Migration guide

Added

topicConfiguration

Topic configuration properties that are relevant for the API

{
    "topicConfiguration" : { 
        "description": "Topic configuration properties that are relevant for the API.", 
        "type": "object", 
        "additionalProperties": false, 
        "properties": { 
            "cleanup.policy": { 
                "description": "The [`cleanup.policy`](https://kafka.apache.org/documentation/#topicconfigs_cleanup.policy) configuration option.", 
                "type": "array", 
                "items":{ 
                    "type": "string", 
                    "enum": ["compact", "delete"] 
                } 
            }, 
            "retention.ms": { 
                "description": "The [`retention.ms`](https://kafka.apache.org/documentation/#topicconfigs_retention.ms) configuration option.", 
                "type": "integer", 
                "minimum": -1
            }, 
            "retention.bytes": { 
                "description": "The [`retention.bytes`](https://kafka.apache.org/documentation/#topicconfigs_retention.bytes) configuration option.", 
                "type": "integer", 
                "minimum": -1
            }, 
            "delete.retention.ms": { 
                "description": "The [`delete.retention.ms`](https://kafka.apache.org/documentation/#topicconfigs_delete.retention.ms) configuration option.", 
                "type": "integer", 
                "minimum": 0
            }, 
            "max.message.bytes": { 
                "description": "The [`max.message.bytes`](https://kafka.apache.org/documentation/#topicconfigs_max.message.bytes) configuration option.", 
                "type": "integer", 
                "minimum": 0
            } 
        } 
    } 
}