>
Confluent
  • Product
    • Confluent Platform
    • KSQL
    • Confluent Hub
    • Subscription
    • Professional Services
    • Training
    • Customers
  • Cloud
    • Confluent Cloud
    • Support
    • Sign Up
    • Log In
    • Cloud FAQ
  • Developers
    • What is Kafka?
    • Resources
    • Events
    • Online Talks
    • Meetups
    • Kafka Summit
    • Kafka Tutorials
    • Confluent Developer
  • About Us
    • Company
    • Partners
    • News
    • Events
    • Careers
    • Contact
  • Blog
  • Docs
  • Download
Get Confluent | Sign up for Confluent Cloud or download Confluent Platform
  • Getting Started
    • What is the Confluent Platform?
      • What is included in the Confluent Platform?
        • Overview
        • Confluent Open Source
          • Confluent Connectors
            • Kafka Connect JDBC Connector
            • Kafka Connect HDFS Connector
            • Kafka Connect Elasticsearch Connector
            • Kafka Connect S3 Connector
          • Confluent Clients
            • C/C++ Client Library
            • Python Client Library
            • Go Client Library
            • .Net Client Library
          • Confluent Schema Registry
          • Confluent REST Proxy
        • Confluent Enterprise
          • Automatic Data Balancing
          • Multi-Datacenter Replication
          • Confluent Control Center
          • JMS Client
        • Confluent Proactive Support
      • Migrating an existing Kafka deployment
        • Migrating developer tools
        • Migrating to Control Center
    • Confluent Platform Quick Start
    • Confluent Cloud Quick Start
      • Step 1: Log into the Confluent Cloud web interface
      • Step 2: Install Confluent Cloud CLI
        • MacOS
        • Linux
        • Windows
      • Step 3: Configure Confluent Cloud CLI
      • Step 4: Create Topics and Produce and Consume to Kafka
      • Step 5: Run Java Examples
      • Supported Clients
        • librdkafka
      • Next Steps
    • Installing and Upgrading
      • Install Confluent Platform
        • System Requirements
          • Operating Systems
          • Software
            • Port Configuration
        • Installing Confluent Platform
          • Docker
          • ZIP and TAR archives
          • Debian and Ubuntu
          • RHEL and CentOS
        • Next Steps
      • Packages
        • Platform Packages
        • Component Packages
      • Installing using Docker
        • Docker Quick Start
          • Installing and Running Docker
          • Getting Started with Docker Compose
          • Getting Started with Docker Client
            • ZooKeeper
            • Kafka
            • Schema Registry
            • REST Proxy
            • Confluent Control Center
              • Stream Monitoring
              • Alerts
            • Kafka Connect
              • Getting Started
              • Monitoring in Control Center
            • Cleanup
        • Docker Configuration
          • Confluent Docker Images
          • Configuration Notes
          • Configuration Parameters
            • ZooKeeper
              • Required Settings
            • Confluent Kafka (cp-kafka)
              • Required Settings
            • Confluent Enterprise Kafka (cp-enterprise-kafka)
              • Required Settings
            • Schema Registry
              • Required Settings
            • Kafka REST Proxy
              • Required Settings
            • Kafka Connect
              • Required Settings
              • Optional Settings
            • Confluent Control Center
              • Docker Options
              • Required Settings
              • Optional Settings
            • Confluent Enterprise Replicator
              • Required Settings
              • Optional Settings
        • Docker Advanced Tutorials
          • Clustered Deployment
            • Installing and Running Docker
            • Docker Client: Setting Up a Three Node Kafka Cluster
            • Docker Compose: Setting Up a Three Node Kafka Cluster
          • Clustered Deployment Using SSL
            • Installing and Running Docker
            • Docker Client: Setting Up a Three Node Kafka Cluster
            • Docker Compose: Setting Up a Three Node Confluent Platform Cluster with SSL
          • Clustered Deployment Using SASL and SSL
            • Installing and Running Docker
            • Docker Client: Setting Up a Three Node Kafka Cluster
            • Docker Compose: Setting Up a Three Node Confluent Platform Cluster with SASL
          • Kafka Connect Tutorial
            • Installing and Running Docker
            • Starting Up Confluent Platform and Kafka Connect
          • Automatic Data Balancing
            • Installing and Running Docker
          • Replicator Tutorial
            • Installing and Running Docker
      • Clients
        • Maven repository for JARs
        • C/C++
        • Python
        • Go
        • .NET
      • Migrating from Open Source to Enterprise
      • Upgrade
        • Preparation
        • Step-by-step Guide
          • Upgrade All Kafka Brokers
          • Upgrade Schema Registry
          • Upgrade Kafka REST Proxy
          • Upgrade Kafka Streams applications
          • Upgrade Kafka Connect
            • Upgrade Kafka Connect Standalone Mode
            • Upgrade Kafka Connect Distributed Mode
          • Upgrade Camus
          • Confluent Control Center
          • Upgrade Other Client Applications
      • Supported Versions and Interoperability
        • Confluent Platform Versions
        • Operating Systems
        • Confluent Control Center
        • Java
        • Scala
        • Component Security
          • Apache Kafka
          • Apache Kafka Connect clients
          • Apache Kafka Streams clients
          • Apache ZooKeeper
          • Confluent Control Center
          • REST Proxy
          • Schema Registry
        • Clients
        • Connectors
        • Cross-Component Compatibility
          • Apache Kafka Connect Workers
          • Apache Kafka Java Clients
          • Apache Kafka Streams Clients
          • Auto Data Balancing
          • Confluent C, C++, Python, Go and .NET
          • Schema Registry
          • REST Proxy
        • Docker and Orchestration Tools
          • DC/OS
          • Docker
    • Command Line Interface
      • Installing and Configuring the CLI
        • Installing the CLI
        • Configuring the CLI
      • Command Reference
        • confluent acl
          • Description
          • Usage
          • Options
          • Positional arguments
        • confluent config
          • Description
          • Usage
          • Options
          • Positional arguments
          • Examples
        • confluent current
          • Description
          • Usage
          • Options
          • Positional arguments
          • Example
        • confluent destroy
          • Description
          • Usage
          • Options
          • Positional arguments
          • Example
        • confluent help
          • Description
          • Usage
          • Options
          • Positional arguments
          • Example
        • confluent list
          • Description
          • Usage
          • Options
          • Positional arguments
          • Examples
        • confluent load
          • Description
          • Usage
          • Options
          • Positional arguments
          • Example
        • confluent log
          • Description
          • Usage
          • Options
          • Positional arguments
          • Examples
        • confluent start
          • Description
          • Usage
          • Options
          • Positional arguments
          • Examples
        • confluent status
          • Description
          • Usage
          • Options
          • Positional arguments
          • Examples
        • confluent stop
          • Description
          • Usage
          • Options
          • Positional arguments
          • Examples
        • confluent top
          • Description
          • Usage
          • Options
          • Positional arguments
          • Example
        • confluent unload
          • Description
          • Usage
          • Options
          • Positional arguments
          • Example
        • Available Commands
        • Environment Variables
    • Tutorials and Resources
      • Confluent Platform Demo (cp-demo)
        • Overview
        • Run Demo
        • Guided Tutorial
          • Brokers
          • Topics
          • Connect
          • ksqlDB
          • Consumers
          • Replicator
          • Security
          • Data Governance with Schema Registry
          • Confluent REST Proxy
          • Failed Broker
          • Alerting
        • Monitoring
        • Troubleshooting
        • Teardown
      • Demos
      • Technical Blogs
      • Video Tutorials and Screencasts
      • White Papers
    • Confluent Platform 4.0.2 Release Notes
      • Highlights
        • Open Source Features
          • Apache Kafka 1.0.2-cp1
      • Previous releases
        • Confluent Platform 4.0.1 Release Notes
          • Highlights
            • Enterprise Features
              • JMS Client
            • Open Source Features
              • Apache Kafka 1.0.1-cp1
        • Confluent Platform 4.0.0 Release Notes
          • Highlights
            • Enterprise Features
              • Control Center: Backward Compatibility
              • Control Center: Improvements
            • Open Source Features
              • JBOD Disk Failure Handling
              • Metrics Improvements
              • Kafka Connect
              • Elasticsearch Connector
              • HDFS Connector
              • S3 Connector
              • JDBC Source Connector
              • Confluent CLI
              • Kafka Streams: Extended Punctuation Semantics
              • Kafka Streams: Deserialization Error Handling
              • Kafka Streams: State Restoration Listener
            • Apache Kafka 1.0.0-cp1
              • Security Failure Handling
              • Java 9 Support
              • Idempotent Producer Performance
              • More Bug Fixes and Improvements
        • Confluent Platform 3.3.1 Release Notes
          • Highlights
            • Enterprise Features
              • Control Center
            • Open Source Features
              • Elasticsearch Sink Connector
              • HDFS Sink Connector
              • S3 Sink Connector
              • JDBC Source Connector
              • librdkafka 0.11.1
              • Kafka Streams: Improved Operability due to Rebalancing Optimizations
              • Apache Kafka 0.11.0.1-cp1
        • Confluent Platform 3.3.0 Release Notes
          • Highlights
            • Enterprise Features
              • REST Proxy ACL Plug-In
              • Control Center Interceptors for Non-Java Clients
              • Control Center
              • Metrics Publisher
            • Open Source Features
              • Exactly-Once Semantics for Apache Kafka
              • Confluent CLI
              • Non-Java Clients
              • Kafka Streams: Confluent serializers/deserializers (serdes) for Avro
              • Kafka Streams: Capacity Planning Guide available
            • Apache Kafka 0.11.0
              • Admin client
              • Record headers
              • Leader epoch in replication protocol
              • Single-threaded controller
            • Classpath Isolation for Apache Kafka Connectors
            • Request rate quotas
            • Kafka Streams: rebalancing improvements
            • More bug fixes and improvements
        • Confluent Platform 3.2.2 Release Notes
          • Highlights
            • Apache Kafka 0.10.2.1-cp2
            • Confluent Control Center
            • Replicator
            • S3 Connector
        • Confluent Platform 3.2.1 Release Notes
          • Highlights
            • Apache Kafka 0.10.2.1
              • Fixes
            • S3 Connector
              • Fixes
        • Confluent Platform 3.2.0 Release Notes
          • Highlights
            • Enterprise Features
              • JMS Client
              • Confluent Control Center
              • Automatic Data Balancing
            • Open Source Features
              • Kafka Streams: Backwards Compatible to Older Kafka Clusters
              • Kafka Streams: Compatibility Matrix
              • Kafka Streams: Session Windows
              • Kafka Streams: Global KTables
              • Kafka Streams: ZooKeeper Dependency Removed
              • Kafka Connect: Single Message Transform
              • S3 Connector
              • .Net Client
              • REST Proxy
              • Apache Kafka 0.10.2
        • Confluent Platform 3.1.2 Release Notes
          • Highlights
            • Apache Kafka 0.10.1.1
              • Fixes
        • Confluent Platform 3.1.1 Release Notes
          • Highlights
            • Enterprise Features
              • Automatic Data Balancing
              • Multi-Datacenter Replication
              • Confluent Control Center
            • Open Source Features
              • Kafka Streams: Interactive Queries
              • Kafka Streams: Application Reset Tool
              • Kafka Streams: Improved memory management
              • Kafka Connect
              • Go Client
            • Apache Kafka 0.10.1
              • New Feature
              • Improvement
              • Bug
              • Task
              • Wish
              • Test
              • Sub-task
        • Confluent Platform 3.1.0 Release Notes
          • Highlights
            • Enterprise Features
              • Automatic Data Balancing
              • Multi-Datacenter Replication
              • Confluent Control Center
            • Open Source Features
              • Kafka Streams
                • Interactive Queries
                • Application Reset Tool
                • Improved memory management
              • Kafka Connect
              • Go Client
          • Apache Kafka 0.10.1
        • Confluent Platform 3.0.1 Release Notes
          • Highlights
            • Confluent Control Center
            • Kafka Streams
              • New Feature: Application Reset Tool
            • Apache Kafka 0.10.0.1
              • New Feature
              • Improvement
              • Bug
              • Test
              • Sub-task
        • Confluent Platform 3.0.0 Release Notes
          • Highlights
            • Kafka Streams
            • Confluent Control Center
            • Apache Kafka 0.10.0.0
            • Deprecating Camus
            • Other Notable Changes
        • Confluent Platform 2.0.1 Release Notes
          • New Java consumer
          • Compatibility
          • Security
          • Performance/memory usage
          • Topic deletion
        • Confluent Platform 2.0.0 Release Notes
          • Security
          • Kafka Connect
          • User Defined Quotas
          • New Consumer
          • New Client Library - librdkafka
          • Proactive Support
          • Compatibility Notes
      • How to Download
      • Questions?
  • Operations
    • Kafka Operations
      • Production Deployment
        • Hardware
          • Memory
          • CPUs
          • Disks
          • Network
          • Filesystem
          • General considerations
        • JVM
        • Important Configuration Options
          • Replication configs
        • File descriptors and mmap
        • Multi-node Configuration
      • Post Deployment
        • Changing configs dynamically
          • cleanup.policy
          • flush.messages
          • flush.ms
          • max.message.bytes
          • min.insync.replicas
          • retention.bytes
          • retention.ms
          • segment.bytes
          • segment.jitter.ms
          • segment.ms
          • unclean.leader.election.enable
        • Logging
        • Admin operations
        • Rolling Restart
        • Performance Tips
        • Software Updates
        • Backup and Restoration
      • Auto Data Balancing
        • Requirements
        • Quickstart
          • Start a Kafka cluster
          • Create topics and produce data
          • Execute the rebalancer
          • Check status and finish
          • Leader balance
          • Decommissioning brokers
          • Limiting Bandwidth Usage during Data Migration
        • Licensing
        • Configuration Options
          • Configuration Options for the rebalancer tool
      • Monitoring Kafka
        • Server Metrics
          • Broker Metrics
          • ZooKeeper Metrics
        • Producer Metrics
          • Global Request Metrics
          • Global Connection Metrics
          • Per-Broker Metrics
          • Per-Topic Metrics
        • New Consumer Metrics
          • Fetch Metrics
          • Topic-level Fetch Metrics
          • Consumer Group Metrics
          • Global Request Metrics
          • Global Connection Metrics
          • Per-Broker Metrics
        • Old Consumer Metrics
      • Confluent Metrics Reporter
        • Installation
        • Configuration
          • Message size
        • Configuration Options
          • Security
          • Authentication
          • Authorization
        • Verification
    • Confluent Control Center
      • Control Center Quick Start
        • Configure Kafka and Kafka Connect
        • Configure and Start Control Center
        • Setup stream monitoring
      • Control Center Concepts
        • Motivation
        • Time windows and metrics
        • Latency
      • Installing and Upgrading Control Center
        • Installing Control Center
          • Configure Kafka and Kafka Connect
          • Configure and start Control Center
          • Next steps
        • Control Center System Requirements
          • Hardware
            • Memory
            • CPUs
            • Disks
            • Network
          • OS
          • JVM
          • User/Cluster Metadata
          • Kafka
          • Multi-Cluster Configuration
          • Dedicated Metric Data Cluster
          • Saturation Testing
            • Test Setup
            • Broker Monitoring
            • Streams Monitoring
          • Example Deployments
            • Broker Monitoring
            • Streams Monitoring
        • Configuring Control Center
          • Base Settings
          • Logging
          • Optional Settings
            • General
            • Monitoring Settings
            • UI Authentication Settings
            • Email Settings
            • Kafka Encryption, Authentication, Authorization Settings
            • HTTPS Settings
            • Internal Kafka Streams Settings
            • Internal Command Settings
        • Installing Control Center Interceptors
          • Interceptor Installation
            • Compatibility
          • Interceptor installation for librdkafka-based clients
          • Client Configuration
            • Adding the interceptor to your Kafka Producer
            • Adding the interceptor to your Kafka Consumer
            • Adding interceptors to your Kafka Streams application
            • Adding the interceptor to librdkafka-based client applications
          • Interceptor Configuration
            • Configuration options
            • Security
            • Logging
            • Example Configuration
          • Verification
        • Installing Control Center on Apache Kafka
          • Software requirements
          • Hardware requirements
            • Install Control Center
          • Installation on Red Hat, CentOS, or Fedora
          • Installation on Debian Linux
            • Install and configure components
          • Installing Confluent Metrics Reporter with Kafka
          • Installing Kafka Connect
          • Installing Confluent Metrics Clients with Kafka Connect
            • Start Control Center
            • License Keys
            • Removing Control Center
          • TAR and ZIP Archives
          • Debian packages
          • Red Hat packages
        • Troubleshooting Control Center
          • Common issues
            • Installing and Setup
              • Bad security configuration
              • InvalidStateStoreException
              • Not enough brokers
              • Local store permissions
              • Multiple Control Center’s with the same ID
              • License expired
            • System health
              • Web interface that is blank or stuck loading
              • I see a rocket ship
              • Nothing is produced on the Metrics (_confluent-metrics) topic
              • Control Center is lagging behind Kafka
              • RecordTooLargeException
              • Parts of the broker or topic table have blank values
            • Streams Monitoring
              • Blank charts
              • Unexpected herringbone pattern
              • Missing consumers or consumer groups
            • Connect
              • I see rocket ship
          • Debugging
            • Check logs
            • Enable debug and trace logging
            • Check configurations
            • Review input topics
            • Size of clusters
            • System check
            • Frontend and REST API
            • Consumer offset lag
            • Enable GC logging
            • Thread dump
            • Data directory
        • Upgrading Control Center
          • Upgrading from version 3.1.x and later
          • Upgrading from version 3.0.x
      • Control Center User Interface
        • System Health
          • Navigation
          • UI Commonalities
          • Broker Aggregate Metrics
          • Produce and Fetch Charts
          • Broker Metrics Table
          • Topic Aggregate Metrics
          • Topic Metrics Table
        • Stream Monitoring
          • Chart Types
          • Page Layout
          • Navigation
          • Time Range and Cluster Selection
          • Summary statistics
          • Missing Metrics Data
          • Example Scenarios
            • Adding a new Consumer Group
              • Latency
              • Expected consumption
        • Kafka Connect
          • Creating new Connectors
          • Editing Sources and Sinks
        • Alerts
          • Concepts
          • User Interface
            • Overview page
            • Integration page
          • Trigger Management
            • New/Edit Trigger Form
            • Topic
            • Consumer Groups
            • Brokers
          • Actions Management
            • New/Edit Action Form
          • Alert History
            • REST API
        • Clusters
          • Setting a Cluster Name
        • Topic Management
          • Detail view for a topic
      • Security
        • Configuring SSL
          • Kafka Brokers
          • Control Center
          • Connect
        • Configuring SASL
          • ZooKeeper
          • Kafka Broker
          • Control Center Configuration
          • Schema Registry Configuration
          • Connect Configuration
        • UI Authentication
        • UI HTTPS
        • Authorization with Kafka ACLS
      • Changelog
        • Version 4.0.1
          • Confluent Control Center
        • Version 4.0.0
          • Confluent Control Center
        • Version 3.3.1
          • Confluent Control Center
        • Version 3.3.0
          • Confluent Control Center
        • Version 3.2.2
          • Confluent Control Center
        • Version 3.2.1
          • Confluent Control Center
        • Version 3.2.0
          • Confluent Control Center
        • Version 3.1.0
          • Confluent Control Center
        • Version 3.0.1
          • Confluent Control Center
    • Confluent Cloud
      • Features Overview
        • Using Confluent Cloud
          • Confluent Cloud Web Interface
          • Confluent Cloud CLI
            • Installing Confluent Cloud CLI on MacOS
            • Installing Confluent Cloud CLI on Linux
            • Installing Confluent Cloud CLI on Windows
        • Connecting Components to Confluent Cloud
          • Connecting Control Center to Confluent Cloud
            • Example
            • Limitations
          • Connecting Kafka Clients to Confluent Cloud
            • Connecting to Confluent Cloud from a .NET Application
            • Connecting to Confluent Cloud from a Go Application
            • Connecting to Confluent Cloud from a Python Application
          • Connecting Kafka Connect to Confluent Cloud
            • Create the Topics in Cloud Cluster
            • Setup a Connect Worker with Confluent Cloud
              • Standalone Cluster
              • Distributed Cluster
          • Connecting Kafka REST Proxy to Confluent Cloud
          • Connecting KSQL to Confluent Cloud
          • Connecting Schema Registry to Confluent Cloud
          • Connecting Kafka Streams to Confluent Cloud
          • Transferring Data into a Confluent Cloud instance
            • Determining What Data is Important
            • Transfer Using Confluent Replicator
            • Transfer Using Apache Kafka MirrorMaker
            • Transitioning to Confluent Cloud
            • Dual Production of Data
        • FAQ for Confluent Cloud
          • General
            • Is Kerberos supported on Confluent Cloud?
            • Can I use Confluent Cloud to do operations on different cloud clusters (prod /integration) without performing init?
            • How do I add users?
            • Can I be auto-notified about failures or incidents?
            • What cloud providers are supported?
          • Billing
            • Can I put my Confluent Cloud account on hold?
            • How does billing work for Confluent Cloud Professional?
            • What payment methods are supported for Confluent Cloud Professional?
            • When am I charged for using Confluent Cloud Professional?
            • What happens if I upgrade or downgrade my cluster?
            • What if I only use part of the month with Confluent Cloud Professional?
            • How do I change the email address used for billing on the Confluent Cloud Professional cluster?
            • Where can I ask billing questions?
        • Debugging Confluent Cloud using kafkacat
    • Multi Data-Center Deployment
      • Replicator Quick Start
        • Start the destination cluster
        • Start the origin cluster
        • Create a topic
        • Configure and run Replicator
      • Installing and Configuring Replicator
        • Install and Configure Kafka Connect Cluster for Replicator
          • Configuring origin and destination brokers
          • Where to Install Connect Workers
          • Running Replicator on Existing Connect Cluster
          • Configuring Logging for Connect Cluster
          • License Key
        • Configure and run a Confluent Replicator on the Connect Cluster
      • Tuning and Monitoring Replicator
        • Sizing Replicator Cluster
        • Getting More Throughput From Replicator Tasks
          • Improving CPU Utilization of a Connect Task
          • Improving Network Utilization of a Connect Task
        • Monitoring Replicator
          • Monitoring Replicator Lag
          • Monitoring Producer and Consumer Metrics
            • Important Producer Metrics
            • Important Consumer Metrics
      • Apache Kafka’s MirrorMaker
        • Comparing Mirror Maker to Confluent Replicator
          • Greater control for reliable replication
          • Deploying, managing, and monitoring
          • Replication Patterns
        • Example of MirrorMaker Use
    • Schema Registry Operations
      • Production Deployment
        • Hardware
        • Memory
        • CPUs
        • Disks
        • Network
        • JVM
        • Important Configuration Options
          • kafkastore.connection.url
          • kafkastore.bootstrap.servers
          • listeners
            • Don’t Modify These Storage Settings
        • Kafka & ZooKeeper
        • Migration from ZooKeeper master election to Kafka master election
          • Downtime for Writes
          • Complete downtime
        • Backup and Restore
      • Monitoring
        • Global Metrics
        • Per-Endpoint Metrics
        • Endpoints
    • Kafka REST Proxy Operations
      • Production Deployment
        • Hardware
          • Memory
          • CPUs
          • Disks
          • Network
        • JVM
        • Deployment
        • Important Configuration Options
        • Don’t Touch These Settings!
        • Post Deployment
      • Monitoring
        • Global Metrics
        • Per-Endpoint Metrics
        • Endpoints
    • Docker Operations
      • Monitoring
        • Using JMX
          • Security on JMX
          • Kafka and ZooKeeper
            • Settings
            • Launching Kafka and ZooKeeper with JMX Enabled
      • Configuring logging
        • log4j Log Levels
        • Component Names
      • Mounting External Volumes
        • Data Volumes for Kafka and ZooKeeper
        • Security: Data Volumes for Configuring Secrets
        • Configuring Connect with External jars
    • Security
      • Security Tutorial
        • Overview
          • Prerequisites
        • Creating SSL Keys and Certificates
          • Generate the keys and certificates
          • Create your own Certificate Authority (CA)
          • Sign the certificate
          • Summary
        • ZooKeeper
        • Brokers
        • Clients
          • Common Configuration
          • Console Producer and Consumer
          • KSQL and Stream Processing Clients
        • Kafka Connect
        • Replicator
        • Confluent Control Center
        • Confluent Metrics Reporter
        • Confluent Monitoring Interceptors
        • Authorization and ACLs
        • Troubleshooting
        • Next Steps
      • Encryption with SSL
        • SSL Overview
        • Creating SSL Keys and Certificates
        • Brokers
          • Optional settings
        • Clients
          • Optional settings
        • ZooKeeper
        • Kafka Connect
        • Confluent Replicator
        • Confluent Control Center
        • Confluent Metrics Reporter
        • Confluent Monitoring Interceptors
          • Interceptors for General Clients
          • Interceptors for Kafka Connect
          • Interceptors for Replicator
        • Schema Registry
        • REST Proxy
        • SSL Logging
      • Encryption and Authentication with SSL
        • SSL Overview
        • Creating SSL Keys and Certificates
        • Brokers
          • Optional settings
        • Clients
          • Optional settings
        • ZooKeeper
        • Kafka Connect
        • Confluent Replicator
        • Confluent Control Center
        • Confluent Metrics Reporter
        • Confluent Monitoring Interceptors
          • Interceptors for General Clients
          • Interceptors for Kafka Connect
          • Interceptors for Replicator
        • Schema Registry
        • REST Proxy
        • SSL Logging
      • Authentication with SASL
        • SASL Overview
        • GSSAPI
          • Configuring GSSAPI
            • SASL/GSSAPI Overview
              • GSSAPI Logging
            • Brokers
              • JAAS
              • Configuration
              • Run
            • Clients
            • ZooKeeper
              • JAAS
              • Configuration
              • Run
            • Kafka Connect
            • Confluent Replicator
            • Confluent Control Center
            • Confluent Metrics Reporter
            • Confluent Monitoring Interceptors
              • Interceptors for General Clients
              • Interceptors for Kafka Connect
              • Interceptors for Replicator
            • Schema Registry
            • REST Proxy
        • SCRAM
          • Configuring SCRAM
            • SASL/SCRAM Overview
            • Brokers
              • JAAS
              • Configuration
              • Run
            • Clients
            • ZooKeeper
            • Kafka Connect
            • Confluent Replicator
            • Confluent Control Center
            • Confluent Metrics Reporter
            • Confluent Monitoring Interceptors
              • Interceptors for General Clients
              • Interceptors for Kafka Connect
              • Interceptors for Replicator
            • Schema Registry
            • REST Proxy
        • PLAIN
          • Configuring PLAIN
            • SASL/PLAIN Overview
            • Brokers
              • JAAS
              • Configuration
              • Run
            • Clients
            • ZooKeeper
            • Kafka Connect
            • Confluent Replicator
            • Confluent Control Center
            • Confluent Metrics Reporter
            • Confluent Monitoring Interceptors
              • Interceptors for General Clients
              • Interceptors for Kafka Connect
              • Interceptors for Replicator
            • Schema Registry
            • REST Proxy
        • JAAS configurations
          • JAAS and Confluent Control Center
        • Enabling multiple SASL mechanisms
        • Modifying SASL mechanisms in a Running Cluster
      • Authorization and ACLs
        • Overview
        • Broker Configuration
          • Authorizer
          • Super Users
          • User Names
        • Using ACLs
          • ACL Format
            • Common cases:
          • Adding ACLs
          • Removing ACLs
          • Listing ACLs
          • Adding or Removing a Principal as Producer or Consumer
        • Authorization in the REST Proxy and Schema Registry
        • Debugging
      • Adding Security to a Running Cluster
        • Migrating Brokers and Clients
        • Migrating ZooKeeper
        • Migrating the ZooKeeper ensemble
      • Streams Security
        • Required ACL setting for secure Kafka clusters
        • Security example
      • Confluent Security Plugins
        • Installation
          • Kafka REST Security Plugin
            • Kafka REST Security Plugin Quick Start
              • Installation
              • Authentication Mechanisms
              • Configuration
            • Principal Propagation
              • SSL
              • SASL
          • Schema Registry Security Plugin
            • Schema Registry Security Plugin Quick Start
              • Installation
              • Authentication Mechanisms
              • Configuration
            • Schema Registry Authorization
              • Schema Registry ACL Authorizer
                • Schema Registry ACL CLI
                  • Adding ACLs
                  • Removing ACLs
                  • List ACLs
              • Topic ACL Authorizer
      • Docker Security
      • Prefixes for Configuring Security
        • Configuration Parameters
        • Environment Variables for Configuring HTTPS
        • Addtional Environment Variables
    • Kafka Connect
      • Kafka Connect Quick Start
        • Goal
        • What we will do
        • Start the services
        • Read File Data with Connect
        • Write File Data with Connect
      • Kafka Connect Concepts
        • Connectors
        • Tasks
          • Task Rebalancing
        • Workers
          • Standalone Workers
          • Distributed Workers
        • Converters
        • Transforms
      • Installing and Configuring Kafka Connect
        • Getting Started
        • Planning for Installation
          • Prerequisites
          • Standalone vs. Distributed
          • Deployment Considerations
        • Installing Plugins
        • Running Workers
          • Standalone Mode
          • Distributed Mode
        • Configuring Workers
          • Common Worker Configs
          • Standalone Worker Configuration
          • Distributed Worker Configuration
          • Configuring Converters
          • Overriding Producer & Consumer Settings
        • Upgrading Kafka Connect Workers
      • Managing Connectors
        • Using Bundled Connectors
        • Configuring Connectors
          • Standalone Example
          • Distributed Example
        • Managing Running Connectors
          • Using the REST Interface
          • Connector and Task Status
          • Common REST Examples
        • Using Community Connectors
        • Upgrading a Connector Plugin
      • Bundled Connectors
        • Confluent JDBC Connector
          • JDBC Source Connector
            • Quick Start
              • Create SQLite Database and Load Data
              • Load the JDBC Source Connector
              • Add a Record to the Consumer
            • Features
            • Configuration
            • Schema Evolution
          • JDBC Source Configuration Options
            • Database Connection Security
            • Database
            • Mode
            • Connector
          • JDBC Sink Connector
            • Quick Start
              • Create SQLite Database and Load Data
              • Load the JDBC Sink Connector
              • Produce a Record in SQLite
            • Features
          • JDBC Sink Configuration Options
            • Database Connection Security
            • Connection
            • Writes
            • Data Mapping
            • DDL Support
            • Retries
          • Changelog
            • Version 4.0.1
              • JDBC Source Connector
              • JDBC Sink Connector
            • Version 4.0.0
              • JDBC Source Connector
              • JDBC Sink Connector
            • Version 3.3.1
              • JDBC Source Connector
              • JDBC Sink Connector
            • Version 3.3.0
              • JDBC Source Connector
              • JDBC Sink Connector
            • Version 3.2.2
            • Version 3.2.1
            • Version 3.2.0
              • JDBC Source Connector
              • JDBC Sink Connector
            • Version 3.1.1
            • Version 3.1.0
              • JDBC Source Connector
              • JDBC Sink Connector
            • Version 3.0.1
              • JDBC Source Connector
            • Version 3.0.0
              • JDBC Source Connector
        • Confluent HDFS Connector
          • HDFS Connector
            • Quickstart
            • Features
            • Configuration
              • Example
              • Format and Partitioner
              • Hive Integration
              • Secure HDFS and Hive Metastore
            • Schema Evolution
          • HDFS Connector Configuration Options
            • HDFS
            • Security
            • Connector
            • Storage
            • Partitioner
            • Hive
            • Schema
          • Changelog
            • Version 4.0.1
            • Version 4.0.0
            • Version 3.3.1
            • Version 3.3.0
            • Version 3.2.2
            • Version 3.2.1
            • Version 3.2.0
            • Version 3.1.1
            • Version 3.1.0
            • Version 3.0.1
              • HDFS Connector
            • Version 3.0.0
              • HDFS Connector
        • Confluent S3 Connector
          • S3 Connector
            • Features
            • Exactly-once delivery on top of eventual consistency
            • Schema Evolution
            • Quickstart
            • Configuration
              • Basic Example
              • Write raw message values into S3
          • S3 Connector Configuration Options
            • Connector
            • S3
            • Storage
            • Partitioner
          • Changelog
            • Version 4.0.1
              • S3 Connector
            • Version 4.0.0
              • S3 Connector
            • Version 3.3.1
              • S3 Connector
            • Version 3.3.0
              • S3 Connector
            • Version 3.2.2
              • S3 Connector
            • Version 3.2.1
              • S3 Connector
            • Version 3.2.0
              • S3 Connector
        • Confluent Elasticsearch Connector
          • Elasticsearch Connector
            • Quick Start
              • Add a Record to the Consumer
              • Load the Elasticsearch Connector
            • Features
            • Delivery Semantics
            • Mapping Management
            • Schema Evolution
            • Automatic Retries
            • Reindexing
            • Security
          • Configuration Options
            • Connector
            • Data Conversion
          • Changelog
            • Version 4.0.1
            • Version 4.0.0
            • Version 3.3.1
            • Version 3.3.0
            • Version 3.2.2
            • Version 3.2.1
            • Version 3.2.0
        • Confluent Replicator
          • Confluent Replicator
            • Features
            • Requirements
            • Quick start
              • Start the target cluster
              • Start the source cluster
              • Configure and run Replicator
            • Topic Renaming
            • Periodic Metadata Updates
            • Security
          • Changelog
            • Version 4.0.1
            • Version 4.0.0
            • Version 3.3.1
            • Version 3.3.0
            • Version 3.2.2
            • Version 3.2.1
            • Version 3.2.0
          • Configuration Options
            • Confluent Platform
            • Source Topics
            • Source Data Conversion
            • Source Zookeeper
            • Source Kafka
            • Source Kafka: Security
            • Source Kafka: Consumer
            • Destination Topics
            • Destination Zookeeper
            • Destination Data Conversion
        • Kafka FileStream Connectors
          • Quickstart
          • FileSource Connector
          • FileSink Connector
      • Kafka Connect Transformations
        • Cast
          • Description
          • Properties
        • ExtractField
          • Description
          • Properties
        • Flatten
          • Description
          • Properties
        • HoistField
          • Description
          • Properties
        • InsertField
          • Description
          • Properties
        • MaskField
          • Description
          • Properties
        • RegexRouter
          • Description
          • Properties
        • ReplaceField
          • Description
          • Properties
        • SetSchemaMetadata
          • Description
          • Properties
        • TimestampConverter
          • Description
          • Properties
        • TimestampRouter
          • Description
          • Properties
        • ValueToKey
          • Description
          • Properties
      • Kafka Connect Security
        • Encryption
        • Authentication
        • Separate principals
        • ACL Considerations
          • Worker ACL Requirements
          • Connector ACL Requirements
      • Kafka Connect Architecture
        • Motivation
        • Architecture
          • Internal Connect Offsets
      • Connector Developer Guide
        • Core Concepts and APIs
          • Connectors and Tasks
          • Partitions and Records
          • Dynamic Connectors
        • Developing a Simple Connector
          • Connector Example
          • Task Example - Source Task
          • Sink Tasks
          • Resuming from Previous Offsets
        • Dynamic Input/Output Partitions
        • Configuration Validation
        • Working with Schemas
        • Schema Evolution
        • Testing
        • Packaging
          • Creating an Archive
          • Creating an Uber JAR
      • Kafka Connect FAQ
        • How do I change the output data format of a SinkConnector?
        • Why does a connector configuration update trigger a task rebalance?
        • Why should I use distributed mode instead of standalone?
        • Do I need to write custom code to use Kafka Connect?
        • Is the Schema Registry a required service to run Kafka Connect?
        • How can I use plain JSON data with Connect?
        • Does source connector X support output format Y?
        • Why is CPU usage high for my Connect worker when no connectors have been deployed?
        • Can connect sink connectors read data written by other clients, e.g. a custom client?
        • After testing a connector in standalone mode, restarting it doesn’t write the data again?
        • Can I use a newer version of Connect with older brokers?
      • Kafka Connect Reference
        • Kafka Connect Javadocs
        • Kafka Connect REST Interface
          • Content Types
          • Statuses & Errors
          • Connectors
          • Tasks
          • Connector Plugins
        • Kafka Connect Worker Configs
          • Common Worker Configs
          • Standalone Worker Configuration
          • Distributed Worker Configuration
    • Camus Operations
      • Important Configuration Options
    • ZooKeeper Operations
      • ZooKeeper Production Deployment
        • Stable version
        • Hardware
          • Memory
          • CPU
          • Disks
        • JVM
        • Important Configuration Options
        • Monitoring
          • Operating System
          • “Four Letter Words”
          • JMX Monitoring
        • Multi-node Setup
      • Post Deployment
  • Development
    • Kafka Streams
      • Introduction
        • The Kafka Streams API in a Nutshell
        • Use Case Examples
        • A Closer Look
      • Requirements
        • Apache Kafka
        • Confluent
      • Kafka Streams Quick Start
        • Purpose
        • Start the Kafka cluster
        • Prepare the topics and the input data
        • Process the input data with Kafka Streams
        • Inspect the output data
        • Stop the Kafka cluster
        • Next steps
      • |ak| Streams Demo Application
        • Requirements
        • Running the |ak| Music demo application
        • Running further Confluent demo applications for the |ak| Streams API
        • Appendix
          • Inspecting the input topics of the |ak| Music application
          • Creating new topics
          • Listing available topics
      • Concepts
        • Kafka 101
        • Stream
        • Stream Processing Application
        • Processor Topology
        • Stream Processor
        • Stateful Stream Processing
        • Duality of Streams and Tables
        • KStream
        • KTable
        • GlobalKTable
        • Time
        • Aggregations
        • Joins
        • Windowing
        • Interactive Queries
        • Processing Guarantees
      • Architecture
        • Processor Topology
        • Parallelism Model
          • Stream Partitions and Tasks
          • Threading Model
          • Example
        • State
        • Memory management
          • Record caches
        • Fault Tolerance
        • Flow Control with Timestamps
        • Backpressure
      • Code Examples
        • Getting started examples
          • Java
          • Scala
        • Security examples
          • Java programming language
        • Interactive queries examples
          • Java
        • End-to-end application examples
          • Java
          • Scala
        • Event-Driven Microservice example
          • Java
      • Developer Guide
        • Writing a Streams Application
          • Libraries and Maven artifacts
          • Using Kafka Streams within your application code
        • Configuring a Streams Application
          • Configuration parameter reference
            • Required configuration parameters
              • application.id
              • bootstrap.servers
            • Optional configuration parameters
              • default.deserialization.exception.handler
              • default.key.serde
              • default.value.serde
              • default.timestamp.extractor
              • num.standby.replicas
              • num.stream.threads
              • partition.grouper
              • processing.guarantee
              • replication.factor
              • state.dir
            • Kafka consumers, producer, and admin client configuration parameters
              • Naming
              • Default Values
              • enable.auto.commit
              • rocksdb.config.setter
            • Recommended configuration parameters for resiliency
              • acks
              • replication.factor
        • Streams DSL
          • Overview
          • Creating source streams from Kafka
          • Transform a stream
            • Stateless transformations
            • Stateful transformations
              • Aggregating
              • Joining
                • Join co-partitioning requirements
                • KStream-KStream Join
                • KTable-KTable Join
                • KStream-KTable Join
                • KStream-GlobalKTable Join
              • Windowing
                • Tumbling time windows
                • Hopping time windows
                • Sliding time windows
                • Session Windows
            • Applying processors and transformers (Processor API integration)
          • Writing streams back to Kafka
        • Processor API
          • Overview
          • Defining a Stream Processor
          • Accessing Processor Context
          • State Stores
            • Defining and creating a State Store
            • Fault-tolerant State Stores
            • Enable or Disable Fault Tolerance of State Stores (Store Changelogs)
            • Implementing Custom State Stores
          • Connecting Processors and State Stores
          • Describing a Topology
        • Data Types and Serialization
          • Configuring SerDes
          • Overriding default SerDes
          • Available SerDes
            • Primitive and basic types
            • Avro
            • JSON
            • Further serdes
          • Implementing custom SerDes
        • Interactive Queries
          • Querying local state stores for an app instance
            • Querying local key-value stores
            • Querying local window stores
            • Querying local custom state stores
          • Querying remote state stores for the entire app
            • Adding an RPC layer to your application
            • Exposing the RPC endpoints of your application
            • Discovering and accessing application instances and their local state stores
          • Demo applications
        • Memory Management
          • Record caches in the DSL
          • Record caches in the Processor API
          • Other memory usage
        • Running Streams Applications
          • Starting a Kafka Streams application
          • Elastic scaling of your application
            • Adding capacity to your application
            • Removing capacity from your application
            • State restoration during workload rebalance
            • Determining how many application instances to run
        • Managing Streams Application Topics
          • User topics
          • Internal topics
        • Streams Security
          • Required ACL setting for secure Kafka clusters
          • Security example
        • Application Reset Tool
          • Step 1: Run the application reset tool
          • Step 2: Reset the local environments of your application instances
            • Example
      • Operations
        • Capacity planning and sizing
          • Background and context
          • Stateless vs. stateful
            • Stateless applications
            • Stateful applications
          • Examples
          • Troubleshooting
        • Monitoring your application
          • Metrics
            • Accessing Metrics
              • Accessing Metrics via JMX and Reporters
              • Accessing Metrics Programmatically
            • Configuring Metrics Granularity
            • Built-in Metrics
              • Thread Metrics
              • Task Metrics
              • Processor Node Metrics
              • State Store Metrics
              • Record Cache Metrics
            • Adding Your Own Metrics
          • Run-time Status Information
            • Status of KafkaStreams instances
            • Monitoring the Restoration Progress of Fault-tolerant State Stores
          • Integration with Confluent Control Center
      • Upgrade Guide
        • Upgrading from CP 3.3.x (Kafka 0.11.0.x-cp1) to CP 4.0.2 (Kafka 1.0.2-cp1)
          • Compatibility
          • Upgrading your Kafka Streams applications to CP 4.0.2
          • API changes
            • Building and running a topology
            • Describing topology and stream task metadata
            • Merging KStreams:
            • Punctuation functions
            • Streams Configuration
            • New classes for optional DSL parameters
          • Full upgrade workflow
        • Upgrading older Kafka Streams applications to CP 4.0.0
          • API changes (from CP 3.2 to CP 3.3)
            • Streams Configuration
            • Local timestamp extractors
            • KTable Changes
          • API changes (from CP 3.1 to CP 3.2)
            • Handling Negative Timestamps and Timestamp Extractor Interface
            • Metrics
            • Scala
          • API changes (from CP 3.0 to CP 3.1)
            • Stream grouping and aggregation
            • Auto Repartitioning
            • TopologyBuilder
            • DSL: New parameters to specify state store names
            • Windowing
      • FAQ
        • General
          • Is Kafka Streams a project separate from Apache Kafka?
          • Is Kafka Streams a proprietary library of Confluent?
          • Do Kafka Streams applications run inside the Kafka brokers?
          • Why Does My Kafka Streams Application Use So Much Memory?
          • What are the system dependencies of Kafka Streams?
          • How do I migrate my older Kafka Streams applications to the latest Confluent Platform version?
          • Which versions of Kafka clusters are supported by Kafka Streams?
          • What programming languages are supported?
          • Why is my application re-processing data from the beginning?
        • Scalability
          • Maximum parallelism of my application? Maximum number of app instances I can run?
        • Processing
          • Accessing record metadata such as topic, partition, and offset information?
          • Difference between map, peek, foreach in the DSL?
          • How to avoid data repartitioning if you know it’s not required?
          • Serdes config method
          • How can I replace RocksDB with a different store?
        • Failure and exception handling
          • Handling corrupted records and deserialization errors (“poison pill records”)?
            • Option 1: Log the error and shut down the application
            • Option 2: Skip corrupted records and log the error
            • Option 3: Quarantine corrupted records (dead letter queue)
            • Option 4: Interpret corrupted records as a sentinel value
          • Sending corrupt records to a quarantine topic or dead letter queue?
        • Interactive Queries
          • Handling InvalidStateStoreException: “the state store may have migrated to another instance”?
        • Security
          • Application fails when running against a secured Kafka cluster?
        • Troubleshooting and debugging
          • Easier to interpret Java stacktraces?
          • Visualizing topologies?
            • Older releases:
          • Inspecting streams and tables?
          • Invalid Timestamp Exception
          • Why do I get an IllegalStateException when accessing record metadata?
          • Why is punctuate() not called?
          • Scala: compile error “no type parameter”, “Java-defined trait is invariant in type T”
          • How can I convert a KStream to a KTable without an aggregation step?
            • Option 1: Write KStream to Kafka, read back as KTable
            • Option 2: Perform a dummy aggregation
          • RocksDB behavior in 1-core environments
      • Javadocs
    • KSQL
      • Download and Learn More
    • Kafka Clients
      • Kafka Consumers
        • Concepts
        • Configuration
        • Initialization
        • Basic Usage
          • Java Client
          • C/C++ Client (librdkafka)
          • Python, Go and .NET Clients
        • Detailed Examples
          • Basic Poll Loop
          • Shutdown with Wakeup
          • Synchronous Commits
          • Asynchronous Commits
        • Administration
          • List Groups
          • Describe Group
      • Kafka Producers
        • Concepts
        • Configuration
        • Examples
          • Initial Setup
          • Asynchronous Writes
          • Synchronous Writes
      • JMS Client
        • Overview
        • Example
        • Requirements
        • Installation
        • Development Guide
          • Configuration
            • Required Configuration Properties
            • Optional Configuration Properties
            • Standard Kafka Configuration Properties (Optional)
            • Confluent Specific Features (Optional)
            • Enabling TLS Encryption (Optional)
          • Developing JMS Applications
            • Creating a ConnectionFactory
            • Creating a Destination
            • Creating a Connection
            • Creating Sessions
            • Producing / Consuming Messages
            • JNDI Context
            • Threading
        • JMS 1.1 Compatibility
          • Features
          • Unsupported Features
            • Session
            • ConnectionFactory
            • Connection
        • Appendix 1 - Creating a Shaded Fat .jar
      • API Docs
    • Connector Developer Guide
      • Core Concepts and APIs
        • Connectors and Tasks
        • Partitions and Records
        • Dynamic Connectors
      • Developing a Simple Connector
        • Connector Example
        • Task Example - Source Task
        • Sink Tasks
        • Resuming from Previous Offsets
      • Dynamic Input/Output Partitions
      • Configuration Validation
      • Working with Schemas
      • Schema Evolution
      • Testing
      • Packaging
        • Creating an Archive
        • Creating an Uber JAR
    • Schema Registry
      • Introduction
        • Quickstart
        • Installation
        • Deployment
        • Development
        • Requirements
        • Contribute
        • License
      • Changelog
        • Version 4.0.1
        • Version 4.0.0
          • Upgrade Notes
        • Version 3.3.0
        • Version 3.2.1
        • Version 3.2.0
        • Version 3.1.1
        • Version 3.1.0
        • Version 3.0.1
        • Version 3.0.0
        • Version 2.0.1
        • Version 2.0.0
      • API Reference
        • Overview
          • Compatibility
          • Content Types
          • Errors
        • Schemas
        • Subjects
        • Compatibility
        • Config
      • Schema Registry Configuration Options
        • kafkastore.connection.url
        • kafkastore.bootstrap.servers
        • listeners
        • avro.compatibility.level
        • host.name
        • kafkastore.ssl.key.password
        • kafkastore.ssl.keystore.location
        • kafkastore.ssl.keystore.password
        • kafkastore.ssl.truststore.location
        • kafkastore.ssl.truststore.password
        • kafkastore.topic
        • kafkastore.topic.replication.factor
        • response.mediatype.default
        • ssl.keystore.location
        • ssl.keystore.password
        • ssl.key.password
        • ssl.truststore.location
        • ssl.truststore.password
        • response.mediatype.preferred
        • zookeeper.set.acl
        • kafkastore.init.timeout.ms
        • kafkastore.security.protocol
        • kafkastore.ssl.enabled.protocols
        • kafkastore.ssl.keystore.type
        • kafkastore.ssl.protocol
        • kafkastore.ssl.provider
        • kafkastore.ssl.truststore.type
        • kafkastore.timeout.ms
        • master.eligibility
        • kafkastore.sasl.kerberos.service.name
        • kafkastore.sasl.mechanism
        • access.control.allow.methods
        • ssl.keystore.type
        • ssl.truststore.type
        • ssl.protocol
        • ssl.provider
        • ssl.client.auth
        • ssl.enabled.protocols
        • access.control.allow.origin
        • debug
        • kafkastore.ssl.cipher.suites
        • kafkastore.ssl.endpoint.identification.algorithm
        • kafkastore.ssl.keymanager.algorithm
        • kafkastore.ssl.trustmanager.algorithm
        • kafkastore.zk.session.timeout.ms
        • metric.reporters
        • metrics.jmx.prefix
        • metrics.num.samples
        • metrics.sample.window.ms
        • port
        • request.logger.name
        • schema.registry.inter.instance.protocol
        • schema.registry.resource.extension.class
        • schema.registry.zk.namespace
        • shutdown.graceful.ms
        • ssl.keymanager.algorithm
        • ssl.trustmanager.algorithm
        • ssl.cipher.suites
        • ssl.endpoint.identification.algorithm
        • kafkastore.sasl.kerberos.kinit.cmd
        • kafkastore.sasl.kerberos.min.time.before.relogin
        • kafkastore.sasl.kerberos.ticket.renew.jitter
        • kafkastore.sasl.kerberos.ticket.renew.window.factor
        • kafkastore.group.id
      • Design Overview
        • Schema ID Allocation
        • Kafka Backend
        • Single Master Architecture
          • Kafka Coordinator Master Election
          • ZooKeeper Master Election
      • Schema Registry Operations
        • Production Deployment
          • Hardware
          • Memory
          • CPUs
          • Disks
          • Network
          • JVM
          • Important Configuration Options
            • kafkastore.connection.url
            • kafkastore.bootstrap.servers
            • listeners
              • Don’t Modify These Storage Settings
          • Kafka & ZooKeeper
          • Migration from ZooKeeper master election to Kafka master election
            • Downtime for Writes
            • Complete downtime
          • Backup and Restore
        • Monitoring
          • Global Metrics
          • Per-Endpoint Metrics
          • Endpoints
      • Multi-DC Setup
        • Overview
        • Kafka Election
          • Recommended Deployment
          • Important Settings
          • Setup
          • Run Book
        • ZooKeeper Election
          • Recommended Deployment
          • Important Settings
          • Setup
          • Run Book
      • Security Overview
        • Kafka Store
        • ZooKeeper
        • Configuring the REST API for HTTP or HTTPS
          • Additional configurations for HTTPS
          • Migrating from HTTP to HTTPS
        • Authorizing Access to the Schemas Topic
      • Serializer and Formatter
        • Serializer
        • Formatter
        • Wire Format
          • Compatibility Guarantees
      • Schema Deletion Guidelines
      • Maven Plugin
        • schema-registry:download
        • schema-registry:test-compatibility
        • schema-registry:register
    • Docker Developer Guide
      • Image Design Overview
        • The Bootup Process
        • Configuration
        • Preflight Checks
        • Launching the Process
        • Development Guidelines
      • Setup
        • Building the Images
        • Running Tests
        • Make Targets
      • Extending the Docker Images
        • Prerequisites
        • Adding Connectors to the Kafka Connect Image
        • Examples
      • Utility Scripts
        • Docker Utility Belt (dub)
        • Confluent Platform Utility Belt (cub)
        • Client Properties
      • References
    • Data Serialization and Evolution
      • Avro
        • Defining an Avro Schema
        • Schema Evolution
        • Backward Compatibility
        • Forward Compatibility
        • Full Compatibility
        • Confluent Schema Registry
    • Kafka REST Proxy
      • Kafka REST Proxy
        • Quickstart
          • Produce and Consume JSON Messages
          • Produce and Consume Avro Messages
          • Produce and Consume Binary Messages
          • Inspect Topic Metadata
        • Features
        • Installation
        • Deployment
        • Development
        • Requirements
        • Contribute
        • License
      • Changelog
        • Version 3.3.0
        • Version 3.2.2
        • Version 3.2.1
        • Version 3.2.0
        • Version 3.1.2
        • Version 3.1.1
        • Version 3.1.0
        • Version 3.0.0
        • Version 2.0.1
        • Version 2.0.0
      • API Reference
        • Overview
          • Content Types
          • Errors
        • API v2
          • Topics
          • Partitions
          • Consumers
          • Brokers
        • API v1
          • Topics
          • Partitions
          • Consumers
          • Brokers
      • REST Proxy Configuration Options
        • Security Configuration Options
      • Configuration Options for HTTPS
      • Configuration Options for SSL Encryption between REST Proxy and Apache Kafka Brokers
      • Configuration Options for SASL Authentication between REST Proxy and Apache Kafka Brokers
        • Interceptor Configuration Options
      • Kafka REST Operations
        • Production Deployment
          • Hardware
            • Memory
            • CPUs
            • Disks
            • Network
          • JVM
          • Deployment
          • Important Configuration Options
          • Don’t Touch These Settings!
          • Post Deployment
        • Monitoring
          • Global Metrics
          • Per-Endpoint Metrics
          • Endpoints
      • Security Overview
    • Application Development
      • kafkacat Utility
        • Consumer Mode
        • Producer Mode
        • Metadata Listing Mode
      • Native Clients with Serializers
        • Java
        • C/C++
      • REST Proxy
    • Confluent Proactive Support
      • What is Proactive Support?
      • How it works
      • Which metadata is collected?
        • Version Collector (default)
        • Confluent Support Metrics (add-on package)
      • Which metadata and data is not being collected?
      • Installing Support Metrics
        • DEB Packages via apt
        • RPM Packages via yum
      • Enabling or disabling the Metrics feature
      • Recommended Proactive Support configuration settings for licensed Confluent customers
      • Proactive Support configuration settings
      • Network ports used by Proactive Support
      • Sharing Proactive Support Metadata with Confluent manually
      • Privacy Policy
    • Confluent Hub
      • Overview
        • Terminology
      • Contributing Components
        • Legal Requirements for Community Submissions
        • Technical Requirements for Submissions
        • Verifying your Submission’s Authenticity
        • Submitting a Component
      • Component Archive Specification
        • Component Archive Format
          • Component Archive Name
          • Component Archive Structure
        • Component Manifests
          • A sample manifest
          • Manifest Field Descriptions
          • Logo Files
          • Verification Level
        • Maven Packaging Plugin
    • Camus
      • Camus
        • Key Features
        • Quickstart
        • Installation
        • Deployment
        • Development
        • Requirements
        • Contribute
        • License
      • Changelog
        • Version 4.0.0
        • Version 3.3.1
        • Version 3.3.0
        • Version 3.2.2
        • Version 3.2.1
        • Version 3.2.0
        • Version 3.1.2
        • Version 3.1.1
        • Version 3.1.0
        • Version 3.0.0
        • Version 2.0.1
        • Version 2.0.0
      • Camus Configuration Options
        • Schema Registry Configuration
        • Camus Job Configuration
        • Kafka Configuration
        • Example Configuration
      • Design
      • Camus Operations
        • Important Configuration Options
  • Docs
  • Operations »
  • Confluent Cloud »
  • Connecting Components to Confluent Cloud
  • View page source

Important

You are viewing documentation for an older version of Confluent Platform. For the latest, click here.

Connecting Components to Confluent Cloud¶

You can connect the Confluent Platform components to Confluent Cloud.

  • Connecting Control Center to Confluent Cloud
  • Connecting Kafka Clients to Confluent Cloud
  • Connecting Kafka Connect to Confluent Cloud
  • Connecting Kafka REST Proxy to Confluent Cloud
  • Connecting KSQL to Confluent Cloud
  • Connecting Schema Registry to Confluent Cloud
  • Connecting Kafka Streams to Confluent Cloud
  • Transferring Data into a Confluent Cloud instance

© Copyright , Confluent, Inc. Privacy Policy | Terms & Conditions. Apache, Apache Kafka, Kafka and the Kafka logo are trademarks of the Apache Software Foundation. All other trademarks, servicemarks, and copyrights are the property of their respective owners.

Please report any inaccuracies on this page or suggest an edit.

Next Previous

Last updated on Jul 11, 2020.

Built with Sphinx using a theme provided by Read the Docs.
    Expand Content v.--