Confluent Cloud

Fully managed Apache Kafka service hosted in Confluent Cloud. Uses Confluent Cloud API keys for authentication.

Quick Example

apiVersion: laminar.io/v1
kind: Profile
spec:
  name: confluent-cloud
  connector: confluent
  config:
    bootstrap_servers: pkc-xxxxx.us-east-1.aws.confluent.cloud:9092
    key: ABCDEFGHIJKLMNOP
    secret: abcdefghijklmnopqrstuvwxyz1234567890
 
---
apiVersion: laminar.io/v1
kind: Table
spec:
  name: events
  connector: confluent
  connection_profile_id: confluent-cloud
  config:
    topic: user-events
    type:
      source_config:
        offset: latest
  schema:
    format:
      json: {}
    fields:
      - field_name: user_id
        field_type:
          type:
            primitive: Int64
        nullable: false
      - field_name: event_type
        field_type:
          type:
            primitive: Utf8
        nullable: false

Configuration

Required

Property	Type	Description
`bootstrap_servers`	string	Confluent Cloud bootstrap servers (from cluster settings)
`key`	string	Kafka cluster API key
`secret`	string	Kafka cluster API secret

Optional (Schema Registry)

Property	Type	Description
`schema_registry.endpoint`	string	Schema Registry URL
`schema_registry.api_key`	string	Schema Registry API key (different from cluster key)
`schema_registry.api_secret`	string	Schema Registry API secret

Getting Credentials

Go to your Confluent Cloud cluster
Click API Keys → Create Key
Copy the key and secret
For Schema Registry, create a separate API key under Schema Registry → API credentials

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"]
}