Get Started Free
Get Started Free
Courses
Apache Kafka 101
Kafka Connect 101
Kafka Streams 101
ksqlDB 101
Inside ksqlDB
Spring Framework and Apache Kafka
Building Data Pipelines with Apache Kafka and Confluent
Event Sourcing and Event Storage with Apache Kafka
Data Mesh 101
Learn
What is Apache Kafka®?
Event Streaming vs. Related Trends
KRaft: Kafka without ZooKeeper
Transactions & Guarantees in Kafka
Processing & Storage Fundamentals of Kafka
Kafka Performance
Cloud-native Kafka
Streaming Database Systems
Testing Apache Kafka
Explore Kafka's Internals
Apache Kafka® FAQs
Design, Build, Run
Event Streaming Patterns
Get Started With Your Favorite Language
Stream Processing Cookbook
Developers: Build Apps
Data Engineers: Build Pipelines and Integrate
Admins: Operate
Demos & In-depth Examples
100 Days Of Code
Community
Kafka Summit Conference
Meetups & Events
Blog
Podcast
Ask the Community
Community Catalysts
Docs
Docs Home
Confluent Cloud
Confluent Platform
Confluent Connectors
Tools
Clients
Courses
Apache Kafka 101
Kafka Connect 101
Kafka Streams 101
ksqlDB 101
Inside ksqlDB
Spring Framework and Apache Kafka
Building Data Pipelines with Apache Kafka and Confluent
Event Sourcing and Event Storage with Apache Kafka
Data Mesh 101
Learn
What is Apache Kafka®?
Event Streaming vs. Related Trends
KRaft: Kafka without ZooKeeper
Transactions & Guarantees in Kafka
Processing & Storage Fundamentals of Kafka
Kafka Performance
Cloud-native Kafka
Streaming Database Systems
Testing Apache Kafka
Explore Kafka's Internals
Apache Kafka® FAQs
Design, Build, Run
Event Streaming Patterns
Get Started With Your Favorite Language
Stream Processing Cookbook
Developers: Build Apps
Data Engineers: Build Pipelines and Integrate
Admins: Operate
Demos & In-depth Examples
100 Days Of Code
Community
Kafka Summit Conference
Meetups & Events
Blog
Podcast
Ask the Community
Community Catalysts
Docs
Docs Home
Confluent Cloud
Confluent Platform
Confluent Connectors
Tools
Clients
Get Started Free
Confluent Documentation
Site Filter
All
Documentation
Confluent Blog
Confluent Developer: Learn Apache Kafka
ksqlDB Documentation
CLOUD
Overview
Get Started
Free Trial for Confluent Cloud
Quick Start for Apache Kafka using Confluent Cloud
Confluent Cloud Console Basics
ksqlDB in Confluent Cloud
Manage Schemas on Confluent Cloud
Confluent Terraform Provider
REST API Quick Start for Confluent Cloud Developers
Confluent Cloud Demos
Kafka Clusters
Features and Limits by Cluster Type
Cluster and Topic Configuration Settings
Create a Cluster with the Console
Expand a Dedicated Cluster
Shrink a Dedicated Cluster
Cluster Management API Quickstart
Cloud Providers and Regions
Compliance for Confluent Cloud
Upgrade Policy for Confluent Cloud
Encrypt a Dedicated Cluster Using Self-managed Keys
Overview
Encrypt Clusters using Self-Managed Keys – AWS
Encrypt Clusters using Self-Managed Keys – Google Cloud
Migrate Topics
Migrate Schemas
Manage Accounts and Access
Resource Hierarchy
Organizations
Organizations
Manage multiple organizations
Environments
Manage Accounts
Service Accounts
User Accounts
Authenticate
API keys
Use API Keys
Best Practices
Troubleshoot
Single sign-on (SSO)
Single sign-on (SSO) for Confluent Cloud
Enable SSO
Control Access
Role-Based Access Control
Access Control Lists
Use the Confluent Cloud CLI with multiple credentials
Tutorial: Access Management in Confluent Cloud
Manage Topics in Cloud Console
Overview
Create, Edit and Delete Topics
Use the Message Browser
Manage Schemas
Design, Tag, Evolve, and Manage Schemas
Using Broker-Side Schema Validation
Schema Linking
Stream Governance
Overview
Stream Lineage
Stream Catalog
User Guide
REST API
GraphQL API
Stream Quality
Cluster Linking
Overview
Quick Start Tutorial
Share Data Across Clusters, Regions, and Clouds
Disaster Recovery and Failover
Hybrid Cloud and Bridge-to-Cloud
Mirror Topics
Data Migration
Security Considerations
Configuration, Commands, and Management
Metrics and Monitoring
Develop Client Applications
Architectural Considerations
Testing
Monitoring clients
Optimizing and Tuning
Overview
Throughput
Latency
Durability
Availability
Configure Clients
Connect to External Systems
Overview
Networking and DNS Considerations
ActiveMQ Source
Amazon CloudWatch Logs Source
Amazon CloudWatch Metrics Sink
Amazon DynamoDB Sink
Amazon Kinesis Source
Amazon Redshift Sink
Amazon SQS Source
Amazon S3 Sink
Amazon S3 Source
AWS Lambda Sink
Azure Blob Storage Sink
Azure Cognitive Search Sink
Azure Cosmos DB Sink
Azure Cosmos DB Source
Azure Data Lake Storage Gen2 Sink
Azure Event Hubs Source
Azure Functions Sink
Azure Service Bus Source
Azure Synapse Analytics Sink
Databricks Delta Lake Sink
Set up Databricks Delta Lake (AWS)
Configure and launch the connector
Datadog Metrics Sink
Datagen Source (development and testing)
Elasticsearch Service Sink
GitHub Source
Google BigQuery Sink
Google Cloud BigTable Sink
Google Cloud Dataproc Sink
Google Cloud Functions Sink
Google Cloud Spanner Sink
Google Cloud Storage Sink
Google Cloud Storage Source
Google Pub/Sub Source
HTTP Sink
IBM MQ Source
InfluxDB 2 Sink
InfluxDB 2 Source
Jira Source
Microsoft SQL Server CDC Source (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)
MySQL Sink (JDBC)
MySQL Source (JDBC)
Oracle CDC Source
Connector Features
Horizontal Scaling
Oracle Database Prerequisites
Configure and Launch the connector
SMT examples
Addressing DDL Changes in Oracle Database
Oracle Database Sink (JDBC)
Oracle Database Source (JDBC)
PagerDuty Sink
PostgreSQL CDC Source (Debezium)
PostgreSQL Sink (JDBC)
PostgreSQL Source (JDBC)
RabbitMQ Source
RabbitMQ Sink
Redis Sink
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
SFTP Sink
SFTP Source
Snowflake Sink
Solace Sink
Splunk Sink
Zendesk Source
Static Egress IP Addresses
Connector Data Previews
Single Message Transforms
View Connector Events
Service Accounts
RBAC for managed connectors
API for fully-managed connectors
Dead Letter Queue
Limitations
Transforms List
Single Message Transforms for Confluent Platform
Cast
Drop
DropHeaders
ExtractField
ExtractTopic
Filter (Apache Kafka)
Filter (Confluent)
Flatten
HoistField
InsertField
InsertHeader
MaskField
MessageTimestampRouter
RegexRouter
ReplaceField
SetSchemaMetadata
TimestampConverter
TimestampRouter
TombstoneHandler
TopicRegexRouter
ValueToKey
Custom transformations
About Preview Features
ksqlDB Stream Processing
Overview
Confluent Cloud quick start
Monitoring ksqlDB
ksqlDB Connector Management in Confluent Cloud
Develop applications for ksqlDB
ksqlDB quick start
Confluent Platform ksqlDB
Manage Networking
Overview
Private Link
Use AWS PrivateLink
Use Azure Private Link
Configure DNS Resolution
VPC and VNet Peering
Overview
Use VPC Peering on AWS
Use VPC Peering on Google Cloud
Use VNet Peering on Azure
Access Confluent Cloud Console
Use Confluent Cloud Schema Registry
AWS Transit Gateway
Static Egress IP Addresses
Test Connectivity
Log and Monitor
Audit Logs
Concepts
Understand Audit Log Records
Event Schema
Authorization and Authentication Events
Organization Events
Access and Consume Audit Log Records
Retain Audit Logs
Best Practices
Troubleshoot
Confluent Cloud Metrics
Cluster Load Metric
Monitor Consumer Lag
Dedicated Cluster Performance and Expansion
Quotas
Service Quotas
Service Quotas API
Billing
Confluent Cloud Billing
Marketplace Consumption Metrics
Azure Marketplace Pay As You Go
Azure Marketplace Commits
AWS Marketplace Pay As You Go
AWS Marketplace Commits
GCP Marketplace Pay As You Go
GCP Marketplace Commits
Marketplace Organization Suspension and Deactivation
Use Confluent Platform with Cloud
Overview
Connecting Control Center to Confluent Cloud
Connect Clients to Confluent Cloud
Connect Kafka Connect to Confluent Cloud
Connecting REST Proxy to Confluent Cloud
Connecting ksqlDB to Confluent Cloud
Manage ksqlDB by using the Confluent CLI
Schema Registry and Confluent Cloud
Connecting Kafka Streams to Confluent Cloud
Auto-Generating Configurations for Components to Confluent Cloud
Confluent Cloud APIs
Confluent Cloud APIs
Metrics API
Stream Catalog REST API
Stream Catalog GraphQL API
Confluent CLI
Confluent Cloud CLI
Release Notes & FAQ
Release Notes
FAQ
Language
Version
Home
ksqlDB
¶
Overview
Confluent Cloud quick start
Monitoring ksqlDB
ksqlDB Connector Management in Confluent Cloud
Develop applications for ksqlDB
ksqlDB quick start
Confluent Platform ksqlDB
On this page: