Confluent Cloud Documentation
Confluent Cloud | Confluent Documentation
Get Started
- Overview
- Quick Start
- REST API Quick Start
- Manage Schemas
- Deploy Free Clusters
- Tutorials and Examples
Manage Kafka Clusters
- Overview
- Cluster Types
- Manage Configuration Settings
- Cloud Providers and Regions
- Resilience
- Copy Data with Cluster Linking
- Copy Data with Replicator
- Resize a Dedicated Cluster
- Multi-Tenancy and Client Quotas for Dedicated Clusters
- Create Cluster Using Terraform
- Create Cluster Using Pulumi
- Connect Confluent Platform and Cloud Environments
- Overview
- Connect Self-Managed Gateway to Cloud
- Connect Self-Managed Control Center to Cloud
- Connect Self-Managed Clients to Cloud
- Connect Self-Managed Connect to Cloud
- Connect Self-Managed REST Proxy to Cloud
- Connect Self-Managed ksqlDB to Cloud
- Connect Self-Managed MQTT to Cloud
- Connect Self-Managed Schema Registry to Cloud
- Connect Self-Managed Streams to Cloud
- Example: Autogenerate Self-Managed Component Configs for Cloud
- Migrate with kcp
- FAQ
Build Streaming Applications
- Overview
- Architectural Considerations
- Client Quick Start
- Configure Clients
- Test and Monitor a Client
- Optimize and Tune
- Client Guides
- Kafka Client APIs
- Deprecated Client APIs
- Client Examples
- VS Code Extension
Build Kafka Streams Applications
- Overview
- Quick Start
- Metrics
- Monitor Applications
- Upgrade Guide
- ksqlDB
- Create Stream Processing Apps with ksqlDB
- Quick Start
- Enable ksqlDB Integration with Schema Registry
- ksqlDB Cluster API Quick Start
- Monitor ksqlDB
- Manage ksqlDB by using the CLI
- Manage Connectors With ksqlDB
- Develop ksqlDB Applications
- Pull Queries
- Grant Role-Based Access
- Migrate ksqlDB Applications on Confluent Cloud
Build AI with Confluent Intelligence
- Overview
- Streaming Agents
- Real-time Context Engine
- Built-in AI/ML Functions
- Create Embeddings
- Run a managed AI model
- Run a remote AI Model
- Search External Tables
- FAQ
Manage Topics
- Overview
- Configuration Reference
- Message Browser
- Share Streams
- Tableflow
- FAQ
Manage and Monitor resource with USM
- Overview
- Register Confluent Platform with USM
- Register Confluent Platform Connect cluster with USM
- Monitor Confluent Platform resources
- Data governance for Confluent Platform
- Troubleshoot
Connect to External Services
- Overview
- Install Connectors
- ActiveMQ Source
- AlloyDB Sink
- Amazon CloudWatch Logs Source
- Amazon CloudWatch Metrics Sink
- Amazon DynamoDB CDC Source
- Amazon DynamoDB Sink
- Amazon Kinesis Source
- Amazon Redshift Sink
- Amazon S3 Sink
- Amazon S3 Source
- Amazon SQS Source
- AWS Lambda Sink
- Azure Blob Storage Sink
- Azure Blob Storage Source
- Azure Cognitive Search Sink
- Azure Cosmos DB Sink
- Azure Cosmos DB Sink V2
- Azure Cosmos DB Source
- Azure Cosmos DB Source V2
- Azure Data Lake Storage Gen2 Sink
- Azure Event Hubs Source
- Azure Functions Sink
- Azure Log Analytics Sink
- Azure Service Bus Source
- Azure Synapse Analytics Sink
- ClickHouse Sink
- Couchbase Source
- Couchbase Sink
- Databricks Delta Lake Sink
- Datadog Metrics Sink
- Datagen Source (development and testing)
- Elasticsearch Service Sink
- GitHub Source
- Google BigQuery Sink [Deprecated]
- Google BigQuery Sink V2
- Google Cloud BigTable Sink
- Google Cloud Dataproc Sink [Deprecated]
- Google Cloud Functions Gen 2 Sink
- Google Cloud Functions Sink [Deprecated]
- Google Cloud Pub/Sub Source
- Google Cloud Spanner Sink
- Google Cloud Storage Sink
- Google Cloud Storage Source
- HTTP Sink
- HTTP Sink V2
- HTTP Source
- HTTP Source V2
- IBM MQ Source
- InfluxDB 2 Sink
- InfluxDB 2 Source
- InfluxDB 3 Sink
- Jira Source
- MariaDB CDC Source
- Microsoft SQL Server CDC Source (Debezium) [Deprecated]
- Microsoft SQL Server CDC Source V2 (Debezium)
- Microsoft SQL Server Sink (JDBC)
- Microsoft SQL Server Source (JDBC)
- MongoDB Atlas Sink
- MongoDB Atlas Source
- MQTT Sink
- MQTT Source
- MySQL CDC Source (Debezium) [Deprecated]
- MySQL CDC Source V2 (Debezium)
- MySQL Sink (JDBC)
- MySQL Source (JDBC)
- Neo4j Sink
- New Relic Metrics Sink
- OpenSearch Sink
- Oracle XStream CDC Source
- Oracle CDC Source
- Oracle Database Sink (JDBC)
- Oracle Database Source (JDBC)
- PagerDuty Sink [Deprecated]
- Pinecone Sink
- PostgreSQL CDC Source (Debezium) [Deprecated]
- PostgreSQL CDC Source V2 (Debezium)
- PostgreSQL Sink (JDBC)
- PostgreSQL Source (JDBC)
- RabbitMQ Sink
- RabbitMQ Source
- Redis Sink
- Redis Kafka Sink
- Redis Kafka Source
- Salesforce Bulk API 2.0 Sink
- Salesforce Bulk API 2.0 Source
- Salesforce Bulk API Source
- Salesforce CDC Source
- Salesforce Platform Event Sink
- Salesforce Platform Event Source
- Salesforce PushTopic Source
- Salesforce SObject Sink
- ServiceNow Sink
- ServiceNow Source [Legacy]
- ServiceNow Source V2
- SFTP Sink
- SFTP Source
- Snowflake Sink
- Snowflake Source
- Solace Sink
- Splunk Sink
- Zendesk Source
- Confluent Hub
- Install Custom Plugins and Custom Connectors
- Manage CSFLE
- Manage Provider Integration
- Networking and DNS
- Overview
- AWS Egress PrivateLink Endpoints for First-Party Services
- AWS Egress PrivateLink Endpoints for Self-Managed Services
- AWS Egress PrivateLink Endpoints for Amazon RDS
- Azure Egress Private Link Endpoints for First-Party Services
- Azure Egress Private Link Endpoints for Self-Managed Services
- Google Cloud Private Service Connect Endpoints for First-Party Services
- Connect API Usage
- Manage Public Egress IP Addresses
- Sample Connector Output
- Configure Single Message Transforms
- Configure Custom SMTs
- View Connector Events
- Interpret Connector Statuses
- Manage Service Accounts
- Configure RBAC
- View Errors in the Dead Letter Queue
- Connector Limits
- Manage Offsets
- Transforms List
- Overview
- Cast
- Drop
- DropHeaders
- EventRouter
- ExtractField
- ExtractTopic
- Filter (Kafka)
- Filter (Confluent)
- Flatten (Kafka)
- Flatten (Confluent)
- FromXML
- GzipDecompress
- HeaderFrom
- HeaderToValue
- HoistField
- InsertField
- InsertHeader
- KeyToValue
- MaskField
- MessageTimestampRouter
- RegexRouter
- ReplaceField (Kafka)
- ReplaceField (Confluent)
- SetSchemaMetadata
- TimestampConverter
- TimestampRouter
- TombstoneHandler
- TopicRegexRouter
- ValueToKey
- Reference
Integrate with Confluent Cloud
- Overview
- Connect with Confluent Program
- Reuse Connections with External Services
- Integrate with Cloud Service Providers
Log and Monitor
- Metrics
- Metrics Integrations
- Manage Notifications
- Monitor Consumer Lag
- Monitor Dedicated Clusters
- Observability for Kafka Clients to Confluent Cloud
- FAQ
Manage Billing
- Overview
- Marketplace Consumption Metrics
- Use AWS Pay As You Go
- Use AWS Commits
- Use Azure Pay As You Go
- Use Azure Commits
- Use Jio Commits
- Use Professional Services on Azure
- Use Google Cloud Pay As You Go
- Use Google Cloud Commits
- Use Professional Services on Google Cloud
- Marketplace Organization Suspension and Deactivation
- FAQ
Manage Service Quotas
APIs
- Confluent Cloud APIs
- Kafka Admin and Produce REST APIs
- Connect API
- Client APIs
- Provider Integration API
- Flink REST API
- Metrics API
- Stream Catalog REST API Usage
- GraphQL API
- Service Quotas API