Confluent Cloud

Fully managed Apache Kafka service hosted in Confluent Cloud.

Connection Profile

• bootstrap_servers (string, required): Comma-separated list of Kafka servers
• key (string, required): Kafka cluster key from Confluent Cloud UI
• secret (string, required): Kafka cluster secret from Confluent Cloud UI
• schema_registry (object, optional): Confluent Schema Registry
  • endpoint (string, required): Schema Registry endpoint
  • api_key (string, optional): Schema Registry API key (different from Kafka cluster key)
  • api_secret (string, optional): Schema Registry API secret

Connection Table

Same as Kafka connector - see Kafka documentation for table configuration.

JSON Schema Reference

Connection Profile Schema

{
  "type": "object",
  "properties": {
    "bootstrap_servers": {"type": "string"},
    "key": {"type": "string"},
    "secret": {"type": "string"},
    "schema_registry": {
      "type": "object",
      "properties": {
        "endpoint": {"type": "string"},
        "api_key": {"type": "string"},
        "api_secret": {"type": "string"}
      }
    }
  },
  "required": ["bootstrap_servers", "key", "secret"]
}

Connection Table Schema

Uses KafkaTable schema - same as Kafka connector.