Get Started Free
  • Get Started Free
  • Courses
      What are the courses?

      Video courses covering Apache Kafka basics, advanced concepts, setup and use cases, and everything in between.

      View all courses
      Kafka® 101
      Kafka® Internal Architecture
      Kafka® Connect 101
      Kafka® Security
      Kafka Streams 101
      NewDesigning Events and Event Streams
      Event Sourcing and Storage
      NewSchema Registry 101
      Data Mesh 101
      ksqlDB 101
      Inside ksqlDB
      Spring Frameworks and Kafka®
      NewKafka® for Python Developers
      Building Data Pipelines
      Confluent Cloud Networking
      Confluent Cloud Security
      NewGoverning Data Streams
  • Learn
      Pick your learning path

      A wide range of resources to get you started

      Start Learning
      Articles

      Deep-dives into key concepts

      Patterns

      Architectures for event streaming

      FAQs

      Q & A about Kafka® and its ecosystem

      100 Days of Code

      A self-directed learning path

      Blog

      The Confluent blog

      Podcast

      Our podcast, Streaming Audio

      Confluent Developer Live

      Free live professional training

      Coding in Motion

      Build a real-time streaming app

  • Build
      Design. Build. Run.

      Build a client app, explore use cases, and build on our demos and resources

      Start Building
      Language Guides

      Build apps in your favorite language

      Tutorials

      Hands-on stream processing examples

      Demos

      More resources to get you started

  • Community
      Join the Community

      Confluent proudly supports the global community of streaming platforms, real-time data streams, Apache Kafka®️, and its ecosystems

      Learn More
      Kafka Summit and Current Conferences

      Premier data streaming events

      Meetups & Events

      Kafka and data streaming community

      Ask the Community

      Community forums and Slack channels

      Community Catalysts

      Sharing expertise with the community

  • Docs
      Get started for free

      Use the Cloud quick start to get up and running with Confluent Cloud using a basic cluster

      Learn more
      Documentation

      Guides, tutorials, and reference

      Confluent Cloud

      Fully managed, cloud-native service

      Confluent Platform

      Enterprise-grade distribution of Kafka

      Confluent Connectors

      Stream data between Kafka and other systems

      Tools

      Operational and developer tools

      Clients

      Use clients to produce and consume messages

Courses
What are the courses?

Video courses covering Apache Kafka basics, advanced concepts, setup and use cases, and everything in between.

View all courses
Kafka® 101
Kafka® Internal Architecture
Kafka® Connect 101
Kafka® Security
Kafka Streams 101
NewDesigning Events and Event Streams
Event Sourcing and Storage
NewSchema Registry 101
Data Mesh 101
ksqlDB 101
Inside ksqlDB
Spring Frameworks and Kafka®
NewKafka® for Python Developers
Building Data Pipelines
Confluent Cloud Networking
Confluent Cloud Security
NewGoverning Data Streams
Learn
Pick your learning path

A wide range of resources to get you started

Start Learning
Articles

Deep-dives into key concepts

Patterns

Architectures for event streaming

FAQs

Q & A about Kafka® and its ecosystem

100 Days of Code

A self-directed learning path

Blog

The Confluent blog

Podcast

Our podcast, Streaming Audio

Confluent Developer Live

Free live professional training

Coding in Motion

Build a real-time streaming app

Build
Design. Build. Run.

Build a client app, explore use cases, and build on our demos and resources

Start Building
Language Guides

Build apps in your favorite language

Tutorials

Hands-on stream processing examples

Demos

More resources to get you started

Community
Join the Community

Confluent proudly supports the global community of streaming platforms, real-time data streams, Apache Kafka®️, and its ecosystems

Learn More
Kafka Summit and Current Conferences

Premier data streaming events

Meetups & Events

Kafka and data streaming community

Ask the Community

Community forums and Slack channels

Community Catalysts

Sharing expertise with the community

Docs
Get started for free

Use the Cloud quick start to get up and running with Confluent Cloud using a basic cluster

Learn more
Documentation

Guides, tutorials, and reference

Confluent Cloud

Fully managed, cloud-native service

Confluent Platform

Enterprise-grade distribution of Kafka

Confluent Connectors

Stream data between Kafka and other systems

Tools

Operational and developer tools

Clients

Use clients to produce and consume messages

Get Started Free
Confluent Documentation
/

CLOUD

  • Overview
  • Get Started
    • Free Trial
    • Quick Start
    • Console Basics
    • Manage Schemas
    • Deploy with Terraform
    • Deploy with Pulumi
    • REST API Quick Start for Developers
    • Connect Confluent Platform and Cloud Environments
      • Overview
      • Connecting Control Center to Confluent Cloud
      • Connect Kafka 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
      • Connect MQTT Proxy to Confluent Cloud
      • Schema Registry and Confluent Cloud
      • Connecting Kafka Streams to Confluent Cloud
      • Autogenerating Configurations for Components to Confluent Cloud
    • Tutorials and Examples
      • Overview of Confluent Cloud Examples
      • ccloud-stack Utility for Confluent Cloud
      • Tutorial: Confluent CLI
      • Observability for Apache Kafka® Clients to Confluent Cloud
        • Observability overview and setup
        • Producer scenarios
          • Overview
          • Confluent Cloud Unreachable
          • Authorization Revoked
        • Consumer scenarios
          • Overview
          • Increasing consumer lag
        • General scenarios
          • Overview
          • Failing to create a new partition
          • Request rate limits
        • Clean up Confluent Cloud resources
        • Additional resources
      • Cloud ETL Example
      • Confluent Replicator to Confluent Cloud Configurations
  • Kafka Clusters
    • Overview
    • Copy Data with Cluster Linking
      • Overview
      • Quick Start
      • Share Data Across Clusters, Regions, and Clouds
      • Disaster Recovery and Failover
      • Hybrid Cloud and Bridge-to-Cloud
      • Tiered Separation of Critical Workloads
      • Mirror Topics
      • Data Migration
      • Security Considerations
      • Private Networking
      • Configuration, Commands, and Management
      • Manage Audit Logs
      • Metrics and Monitoring
      • FAQs
      • Troubleshooting
    • Copy Data with Replicator
      • Quick Start
      • Use Replicator to Migrate Topics
    • Cluster and Topic Configuration Settings
    • Manage Clusters
    • Cloud Providers and Regions
    • Resize a Dedicated Cluster
    • Multi-tenancy and Client Quotas for Dedicated Clusters
    • Encrypt a Dedicated Cluster Using Self-managed Keys
      • Overview
      • Encrypt Clusters using Self-Managed Keys – AWS
      • Encrypt Clusters using Self-Managed Keys – Azure
      • Encrypt Clusters using Self-Managed Keys – Google Cloud
    • Upgrade Policy
    • Compliance
    • Resilience
  • Build Client Applications
    • Overview
    • Quick Start
    • Guides
      • Python Client
      • .NET Client
      • Go Client
      • Java Client
      • C++ Client
      • JMS Client
    • Examples
      • Overview
      • C/C++ Example
      • .NET Example
      • Go Example
      • Spring Boot Example
      • Java Example
      • KafkaProducer Example
      • Python Example
      • REST Example
      • Node.js Example
      • Clojure Example
      • Groovy Example
      • Kafka Connect Datagen Example
      • kafkacat Example
      • Kotlin Example
      • Ruby Example
      • Rust Example
      • Scala Example
    • Architecture
    • Test
    • Monitor
    • Optimize and Tune
      • Overview
      • Throughput
      • Latency
      • Durability
      • Availability
  • Manage Accounts and Access
    • Resource Hierarchy
      • Organizations
        • Overview
        • Manage Multiple Organizations
      • Environments
    • Manage Accounts
      • Service Accounts
      • User Accounts
    • Authenticate
      • Use API keys
        • Overview
        • Best Practices
        • Troubleshoot
      • Use OAuth
        • OAuth for Confluent Cloud
        • Add an OAuth/OIDC identity provider
        • Use identity pools and filters
        • Refresh the JWKS URI
        • Configure OAuth clients
        • Access Kafka REST APIs
        • Best Practices
      • Use 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 CLI with multiple credentials
    • Access Management Tutorial
  • Manage Topics
    • Overview
    • Create, Edit and Delete Topics
    • Use the Message Browser
  • Govern Streams and Schemas
    • Stream Governance
      • Overview
      • Packages, Features, and Limits
      • Schema Registry Clusters API Quick Start
      • Stream Lineage
      • Stream Catalog
        • User Guide
        • REST API
        • GraphQL API
      • Stream Quality
      • Generate an AsyncAPI Specification for Confluent Cloud Clusters
    • Manage Schemas
    • Confluent Cloud Schema Registry Tutorial
    • Schema Registry REST API
    • Using Broker-Side Schema Validation
    • Schema Linking
  • Connect to External Systems
    • Overview
    • Install Managed Connectors
      • ActiveMQ Source
      • AlloyDB Sink
      • 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 Blob Storage Source
      • 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 Log Analytics 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 Cloud Pub/Sub Source
      • HTTP Sink
      • HTTP Source
      • 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)
      • New Relic Metrics Sink
      • Oracle CDC Source
        • Connector Features
        • Horizontal Scaling
        • Oracle Database Prerequisites
        • Configure and Launch the connector
        • SMT examples
        • DDL Changes
        • Troubleshooting
      • 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 Bulk API 2.0 Sink
      • Salesforce Bulk API 2.0 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
    • Networking, DNS, and Service Endpoints
    • Connect API
    • Manage Static Egress IP Addresses
    • Preview Connector Output
    • Configure Single Message Transforms
    • View Connector Events
    • Manage Service Accounts
    • Configure RBAC
    • View Errors in the Dead Letter Queue
    • Connector Limits
    • Transforms List
      • Single Message Transforms for Confluent Platform
      • Cast
      • Drop
      • DropHeaders
      • ExtractField
      • ExtractTopic
      • Filter (Apache Kafka)
      • Filter (Confluent)
      • Flatten
      • GzipDecompress
      • HeaderFrom
      • HoistField
      • InsertField
      • InsertHeader
      • MaskField
      • MessageTimestampRouter
      • RegexRouter
      • ReplaceField
      • SetSchemaMetadata
      • TimestampConverter
      • TimestampRouter
      • TombstoneHandler
      • TopicRegexRouter
      • ValueToKey
      • Custom transformations
  • Process Data Streams
    • Build Data Pipelines with Stream Designer
      • Overview
      • Quick Start for Stream Designer
      • Create a join pipeline
      • Create an aggregation pipeline
      • Import a recipe into a pipeline
      • Import and export a pipeline
      • Edit and update a pipeline
      • Role-Based Access Control for pipelines
      • Troubleshooting a pipeline in Stream Designer
      • Manage pipelines with the CLI
      • Manage pipelines with the REST API
      • Manage pipeline secrets
    • Create Stream Processing Apps with ksqlDB
      • Overview
      • Confluent Cloud Quick Start
      • Enable ksqlDB integration with Schema Registry
      • ksqlDB Cluster API Quick Start
      • Monitoring ksqlDB
      • ksqlDB Connector Management in Confluent Cloud
      • Develop applications for ksqlDB
      • Pull queries with Confluent Cloud ksqlDB
      • ksqlDB quick start
      • Grant Role-Based Access to a ksqlDB cluster
      • Confluent Platform ksqlDB
  • Manage Networking
    • Overview
    • Private Endpoints
      • Use AWS PrivateLink
      • Use Azure Private Link
      • Use Google Cloud Private Service Connect
    • VPC and VNet Peering
      • Overview
      • Use VPC Peering on AWS
      • Use VPC Peering on Google Cloud
      • Use VNet Peering on Azure
      • Use Confluent Cloud Schema Registry
    • AWS Transit Gateway
    • Access Confluent Cloud Console with Private Networking
    • Static Egress IP Addresses
    • Test Connectivity
  • Log and Monitor
    • Audit Logs
      • Concepts
      • Understand Audit Log Records
      • Event Schema
      • Auditable Event Methods
        • Kafka Cluster Authentication and Authorization
        • Schema Registry Authentication and Authorization
        • Kafka Cluster Management
        • OAuth/OIDC Identity Provider and Identity Pool
        • Organization
        • Networking
        • Pipeline (Stream Designer)
        • Role-based Access Control (RBAC)
      • Access and Consume Audit Log Records
      • Retain Audit Logs
      • Best Practices
      • Troubleshoot
    • Metrics
    • Use the Metrics API to Track Usage by Team
    • Notifications
    • Cluster Load Metric
    • Monitor Consumer Lag
    • Dedicated Cluster Performance and Expansion
  • Manage Billing
    • Overview
    • 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
  • Manage Service Quotas
    • Overview
    • Service Quotas API
  • APIs
    • Confluent Cloud APIs
    • Cluster Management with Kafka REST API
    • Metrics API
    • Stream Catalog REST API
    • GraphQL API
    • Service Quotas API
    • Pipelines API
  • Confluent CLI
  • Release Notes & FAQ
    • Release Notes
    • FAQ
  • Support
  1. Home
  2. Cloud

Process Data Streams in Confluent Cloud¶

  • Build Data Pipelines with Stream Designer
    • Overview
    • Quick Start for Stream Designer
    • Create a join pipeline
    • Create an aggregation pipeline
    • Import a recipe into a pipeline
    • Import and export a pipeline
    • Edit and update a pipeline
    • Role-Based Access Control for pipelines
    • Troubleshooting a pipeline in Stream Designer
    • Manage pipelines with the CLI
    • Manage pipelines with the REST API
    • Manage pipeline secrets
  • Create Stream Processing Apps with ksqlDB
    • Overview
    • Confluent Cloud Quick Start
    • Enable ksqlDB integration with Schema Registry
    • ksqlDB Cluster API Quick Start
    • Monitoring ksqlDB
    • ksqlDB Connector Management in Confluent Cloud
    • Develop applications for ksqlDB
    • Pull queries with Confluent Cloud ksqlDB
    • ksqlDB quick start
    • Grant Role-Based Access to a ksqlDB cluster
    • Confluent Platform ksqlDB

Confluent Cloud is a fully-managed Apache Kafka service available on all three major clouds. Try it free today.

Get Started Free
  • Confluent
  • About
  • Careers
  • Contact
  • Professional Services
  • Product
  • Confluent Cloud
  • ksqlDB
  • Developer
  • Free Courses
  • Tutorials
  • Event Streaming Patterns
  • Documentation
  • Blog
  • Podcast
  • Community
  • Forum
  • Meetups
  • Kafka Summit
  • Catalysts
Terms & Conditions Privacy Policy Do Not Sell My Information Modern Slavery Policy Cookie Settings Feedback

Copyright © Confluent, Inc. 2014- . Apache, Apache Kafka, Kafka, and associated open source project names are trademarks of the Apache Software Foundation

On this page: