>
Confluent
  • Product
    • KSQLLearn about KSQL, Streaming SQL for Apache Kafka and what it can do.
      Play
    • 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
  • About Us
    • What is Apache Kafka
    • Company
    • Partners
    • News
    • Events
    • Careers
    • Contact
  • Blog
  • Docs
  • Download
  • 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
        • Confluent Clients
          • C/C++ Client Library
          • Python Client Library
          • Go Client Library
        • Confluent Schema Registry
        • Confluent REST Proxy
      • Confluent Enterprise
        • Automatic Data Balancing
        • Multi-Datacenter Replication
        • Confluent Control Center
      • Confluent Proactive Support
    • Migrating an existing Kafka deployment
      • Migrating developer tools
      • Migrating to Control Center
  • Confluent Platform 3.1.2 Release Notes
    • Highlights
      • Apache Kafka 0.10.1.1
        • Fixes
    • Previous releases
      • Confluent Platform 3.1.1 Release Notes
        • 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.0.1 Release Notes
        • 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
        • Kafka Streams
        • Confluent Control Center
        • Apache Kafka 0.10.0.0
        • Deprecating Camus
        • Other Notable Changes
      • Confluent Platform 2.0.1 Release Notes
      • Confluent Platform 2.0.0 Release Notes
    • How to Download
    • Questions?
  • Data Serialization and Evolution
    • Introduction
    • Avro
      • Defining an Avro Schema
      • Schema Evolution
      • Backward Compatibility
      • Forward Compatibility
      • Full Compatibility
      • Confluent Schema Registry
  • Installation
    • Confluent Platform Installation
      • Requirements
      • ZIP and TAR archives
      • DEB packages via apt
      • RPM packages via yum
      • Available Packages
      • Migrating from Confluent Open Source to Confluent Enterprise
    • Clients
      • Maven repository for jars
      • C/C++
      • Python
      • Go
  • 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
      • Upgrade Other Client Applications
      • Confluent Control Center
  • Confluent Platform Quickstart
  • Application Development
    • Native Clients with Serializers
      • Java
      • C/C++
    • REST Proxy
  • Operations
    • Kafka Operations
      • Production Deployment
        • Hardware
          • Memory
          • CPUs
          • Disks
          • Network
          • Filesystem
          • General considerations
        • JVM
        • Important Configuration Options
          • Replication configs
        • File descriptors and mmap
        • Zookeeper
          • Stable version
          • Operationalizing ZooKeeper
        • Mirroring data between clusters
      • Post Deployment
        • Tweaking configs dynamically
        • Logging
          • Controller
          • State Change Log
          • Request logging
        • Admin operations
          • Adding topics
          • Modifying topics
          • Deleting topics
          • Graceful shutdown
          • Scaling the Cluster
          • Increasing replication factor
          • Limiting Bandwidth Usage during Data Migration
          • Balancing Replicas Across Racks
          • Enforcing Client Quotas
        • Performance Tips
          • Picking the number of partitions for a topic
          • Lagging replicas
          • Increasing consumer throughput
        • Software Updates
        • Backup and Restoration
      • Confluent Rebalancer
        • 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
          • Configuration Options for the metrics publisher
      • Monitoring Kafka
        • Server 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
    • Schema Registry Operations
      • Production Deployment
        • Hardware
          • Memory
          • CPUs
          • Disks
          • Network
        • JVM
        • Important Configuration Options
        • Don’t Touch These Settings!
          • Storage settings
        • Kafka & ZooKeeper
        • Multi-DC Setup
          • Overview
          • Recommended Deployment
          • Important Settings
          • Setup
          • Run Book
      • 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
    • Camus Operations
      • Important Configuration Options
  • Docker
    • Introduction
      • Choosing the Right Images
      • Requirements
      • Important Notes/Caveats
      • License
    • Quickstart
      • Installing & Running Docker
      • Running Confluent Platform on Docker
        • Zookeeper
        • Kafka
        • Schema Registry
        • REST Proxy
        • Confluent Control Center
          • Stream Monitoring
          • Alerts
        • Kafka Connect
          • Getting Started
          • Monitoring in Control Center
        • Cleanup
      • Getting Started with Docker Compose
    • Security Overview
      • Docker Security
    • Configuration
      • 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
    • Operations
      • Monitoring
        • Using JMX
          • Security on JMX
          • Kafka & Zookeeper
            • Settings
            • Launching Kafka and Zookeeper with JMX Enabled
      • Configuring logging
        • log4j Log Levels
        • Component Names
      • Mounting External Volumes
        • Data Volumes for Kafka & Zookeeper
        • Security: Data Volumes for Configuring Secrets
        • Configuring Connect with External jars
    • More Tutorials
      • Clustered Deployment
        • Installing & 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 & Running Docker
        • Docker Client: Setting Up a Three Node Kafka Cluster
        • Docker Compose: Setting Up a Three Node CP Cluster with SSL
      • Clustered Deployment Using SASL and SSL
        • Installing & Running Docker
        • Docker Client: Setting Up a Three Node Kafka Cluster
        • Docker Compose: Setting Up a Three Node CP Cluster with SASL
      • Kafka Connect Tutorial
        • Installing & Running Docker
        • Starting Up Confluent Platform & Kafka Connect
      • Automatic Data Balancing
        • Installing & Running Docker
      • Replicator Tutorial
        • Installing & Running 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
    • How to Contribute
      • General Guidelines
      • GitHub Workflow
  • Confluent Control Center
    • Introduction
    • Quickstart
    • Concept Guide
      • Motivation
      • Time windows and metrics
      • Latency
    • Requirements
    • Installation
      • Installation on RedHat, Centos, or Fedora
      • Installation on Debian Linux
      • Other systems
        • Installing Kafka Connect
        • Installing Confluent Metrics Clients with Kafka Connect
        • Starting Control Center
      • License Keys
      • Removing Control Center
        • TAR and ZIP Archives
        • Debian packages
        • Redhat packages
    • Kafka Client Guide
      • Interceptor Installation
      • Application Configuration
        • Adding the interceptor to your Kafka Producer
        • Adding the interceptor to your Kafka Consumer
        • Adding interceptors to your Kafka Streams application
      • Interceptor Configuration
        • Logging
        • Configuration options
        • Example Configuration
      • Multi Cluster Configuration
        • Dedicated Metric Data Cluster
    • Configuration
      • Required Settings
      • Optional Settings
      • UI Authentication Settings
      • Email Settings
      • Kafka Encryption, Authentication, Authorization Settings
      • HTTPS Settings
      • Internal Kafka Streams Settings
      • Internal Command Settings
    • Web User Interface
      • 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
        • Trigger Management
          • New/Edit Trigger Form
        • Actions Management
          • New/Edit Action Form
        • Alert History
      • Clusters
        • Setting a Cluster Name
    • Security
      • UI Authentication
      • UI HTTPS
      • Kafka
        • Authorization with Kafka ACLS
    • Operations
      • Hardware
        • Memory
        • CPUs
        • Disks
        • Network
      • OS
      • JVM
      • Kafka
    • Upgrading
      • Upgrading from version 3.0.x
    • Changelog
      • Version 3.0.1
        • Confluent Control Center
  • Kafka Security
    • Encryption and Authentication using SSL
      • Overview
      • Generate SSL key and certificate for each Kafka broker
      • Creating your own CA
      • Signing the certificate
      • Configuring Kafka Brokers
      • Configuring Kafka Clients
      • Enabling SSL Logging
    • Authentication using SASL
      • SASL configuration for Kafka brokers
      • SASL configuration for Kafka Clients
      • Authentication using SASL/Kerberos
        • Prerequisites
          • Kerberos
          • Kerberos Principals
          • All hosts must be reachable using hostnames
        • Configuring Kafka Brokers
        • Configuring Kafka Clients
      • Authentication using SASL/PLAIN
        • Configuring Kafka Brokers
        • Configuring Kafka Clients
        • Use of SASL/PLAIN in production
      • Enabling multiple SASL mechanisms in a broker
      • Modifying SASL mechanisms in a Running Cluster
      • Enabling Logging for SASL
    • Authorization and ACLs
      • Overview
        • Common cases:
        • Further configuration:
      • Command Line Interface
        • Adding ACLs
        • Removing ACLs
        • List ACLs
        • Adding or Removing a Principal as Producer or Consumer
        • Enabling Authorizer Logging for Debugging
    • Adding Security to a Running Cluster
    • ZooKeeper Authentication
      • New clusters
      • Migrating clusters
      • Migrating the ZooKeeper ensemble
    • Kafka Security & the Confluent Platform
      • Other Observations
  • Kafka Streams
    • Introduction
      • Kafka Streams – The Power without the Weight
      • A closer look
    • Requirements
    • Quickstart
      • Goal of this quickstart
      • What we want to do
      • Start the Kafka cluster
      • Prepare the input data
      • Process the input data with Kafka Streams
      • Inspect the output data
      • Stop the Kafka cluster
      • Where to go from here
    • Concepts
      • Kafka 101
      • Stream
      • Stream Processing Application
      • Processor Topology
      • Stream Processor
      • Time
      • Stateful Stream Processing
      • Duality of Streams and Tables
      • KStream (record stream)
      • KTable (changelog stream)
      • Windowing
      • Joins
      • Aggregations
    • Architecture
      • Processor Topology
      • Parallelism Model
        • Stream Partitions and Tasks
        • Threading Model
        • Example
      • State
      • Memory management
        • Record caches
      • Fault Tolerance
      • Processing Guarantees
      • Flow Control with Timestamps
      • Backpressure
    • Developer Guide
      • Code examples
        • Application examples for Kafka Streams in Apache Kafka
        • Application examples for Kafka Streams provided by Confluent
          • Simple examples
          • Security examples
          • Interactive Queries examples
          • End-to-end demo applications
      • Configuring a Kafka Streams application
        • Overview
        • Required configuration parameters
        • Optional configuration parameters
        • Non-Streams configuration parameters
      • Writing a Kafka Streams application
        • Overview
        • Libraries and maven artifacts
        • Using Kafka Streams within your application code
        • Processor API
          • Overview
          • Defining a Stream Processor
          • Defining a State Store
          • Enable / Disable State Store Changelogs
          • Connecting Processors and Stores
        • Kafka Streams DSL
          • Overview
          • Creating source streams from Kafka
          • Transform a stream
            • Stateless transformations
            • Stateful transformations
            • Windowing a Stream
            • Joining Streams
            • Applying a custom processor
          • Writing streams back to Kafka
      • Interactive Queries
        • Overview
        • Demo applications
        • Your application and interactive queries
        • Querying local state stores (for an application instance)
          • Querying local key-value stores
          • Querying local window stores
          • Querying local custom state stores
        • Querying remote state stores (for the entire application)
          • Adding an RPC layer to your application
          • Exposing the RPC endpoints of your application
          • Discovering and accessing application instances and their respective local state stores
      • Memory management
        • Record caches in the DSL
        • State store caches in the Processor API
        • Other memory usage
      • Running a Kafka Streams application
        • Starting a Kafka Streams application
        • Elastic scaling of your application
          • Adding capacity to your application (“expand”)
          • Removing capacity from your application (“shrink”)
          • State restoration during workload rebalance
          • How many application instances to run?
      • Managing topics of a Kafka Streams application
      • Data types and serialization
        • Overview
        • Configuring default serializers/deserializers (serdes)
        • Overriding default serializers/deserializers (serdes)
        • Available serializers/deserializers (serdes)
        • Implementing custom serializers/deserializers (serdes)
      • Security
        • Overview
        • Security example
      • Application Reset Tool
        • Overview
        • Scope
        • Usage
          • Step 1: Run the application reset tool
          • Step 2: Reset the local environments of your application instances
        • Example
    • Upgrade Guide
      • Upgrading from CP 3.0.x (Kafka 0.10.0.x-cp2) to CP 3.1.2 (Kafka 0.10.1.1-cp1)
        • Compatibility
        • Upgrading your Kafka Streams applications to CP 3.1.2
        • API changes
          • Stream grouping and aggregation
          • Auto Repartitioning
          • TopologyBuilder
          • DSL: New parameters to specify state store names
          • Windowing
        • Full upgrade workflow
    • 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?
        • What are the system dependencies of Kafka Streams?
        • How do I migrate my Kafka Streams applications CP 3.0.x applications to CP 3.1.2
        • Can I use Kafka Streams with Kafka clusters running 0.9, 0.8, or 0.7?
      • Troubleshooting and debugging
        • Java stacktraces
        • Inspecting topologies
        • Inspecting streams
        • Invalid Timestamp Exception
        • Why is punctuate() not called?
        • How can I convert a KStream to a KTable without an aggregation step?
    • Javadocs
  • Kafka Connect
    • Introduction
    • Requirements
    • Quickstart
      • Goal of this quickstart
      • What we will do
      • Start ZooKeeper, Kafka, Schema Registry
      • Read File Data with Connect
      • Write File Data with Connect
    • Concepts
      • Connectors
      • Tasks
        • Task Rebalancing
      • Workers
        • Standalone Workers
        • Distributed Workers
      • Converters
    • Installing and Configuring Kafka Connect
      • Getting Started
      • Planning for Installation
        • Prerequisites
        • Standalone vs. Distributed
        • Deployment Considerations
      • Installing Connector 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
          • Quickstart
          • Features
            • Incremental Query Modes
          • Configuration
            • JDBC Drivers
            • Examples
          • Schema Evolution
        • JDBC Source Configuration Options
          • Database
          • Connector
          • Mode
        • JDBC Sink Connector
          • Quickstart
          • Features
            • Data mapping
            • Key handling
            • Idempotent writes
            • Auto-creation and Auto-evoluton
        • JDBC Sink Configuration Options
          • Connection
          • Writes
          • Data Mapping
          • DDL Support
          • Retries
        • Changelog
          • 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
        • Configuration Options
          • HDFS
          • Hive
          • Security
          • Schema
          • Connector
          • Internal
        • Changelog
          • Version 3.1.1
          • Version 3.1.0
          • Version 3.0.1
            • HDFS Connector
          • Version 3.0.0
            • HDFS Connector
      • Confluent Elasticsearch Connector
        • Elasticsearch Connector
          • Quickstart
          • Features
          • Delivery Semantics
          • Mapping Management
          • Schema Evolution
          • Reindexing
          • Security
        • Configuration Options
      • Confluent Replicator
        • Confluent Replicator
          • Features
          • Requirements
          • Quickstart
            • Start the target cluster
            • Start the source cluster
            • Configure and run Replicator
          • Topic Renaming
          • Periodic Metadata Updates
          • Security
        • 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
    • Security
      • Configuring Workers with Security
      • Configuring Connectors with Security
      • ACL Considerations
        • Worker ACL Requirements
        • Connector ACL Requirements
    • Architecture & Internals
      • 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
    • 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?
    • Reference
      • Javadocs
      • REST Interface
        • Content Types
        • Statuses & Errors
        • Connectors
        • Tasks
        • Connector Plugins
      • All Worker Configs
        • Common Worker Configs
        • Standalone Worker Configuration
        • Distributed Worker Configuration
  • Kafka Clients
    • Kafka Consumers
      • Concepts
      • Configuration
      • Initialization
      • Basic Usage
        • Java Client
        • C/C++ Client (librdkafka)
        • Python Client
        • Go Client
      • 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
    • API Docs
  • Schema Registry
    • Schema Registry
      • Quickstart
      • Installation
      • Deployment
      • Development
      • Requirements
      • Contribute
      • License
    • Changelog
      • Version 3.1.1
      • Version 3.1.0
        • Schema Registry
        • Serializers, Formatters, and Converters
      • Version 3.0.1
        • Schema Registry
        • Serializers, Formatters, and Converters
      • Version 3.0.0
        • Schema Registry
        • Serializers, Formatters, and Converters
      • Version 2.0.1
        • Schema Registry
      • Version 2.0.0
        • Schema Registry
        • Serializers, Formatters, and Converters
    • API Reference
      • Overview
        • Compatibility
        • Content Types
        • Errors
      • Schemas
      • Subjects
      • Compatibility
      • Config
    • Configuration Options
    • Design Overview
      • Batch ID Allocation
      • Kafka Backend
      • Single Master Architecture
    • Operations
      • Production Deployment
        • Hardware
          • Memory
          • CPUs
          • Disks
          • Network
        • JVM
        • Important Configuration Options
        • Don’t Touch These Settings!
          • Storage settings
        • Kafka & ZooKeeper
        • Multi-DC Setup
          • Overview
          • Recommended Deployment
          • Important Settings
          • Setup
          • Run Book
      • Monitoring
        • Global Metrics
        • Per-Endpoint Metrics
        • Endpoints
    • Security Overview
      • Kafka Store
      • ZooKeeper
    • Serializer and Formatter
      • Serializer
      • Formatter
      • Wire Format
        • Compatibility Guarantees
    • Maven Plugin
      • schema-registry:download
      • schema-registry:test-compatibility
      • schema-registry:register
  • Kafka REST Proxy
    • Kafka REST Proxy
      • Quickstart
        • Produce and Consume Avro Messages
        • Produce and Consume JSON Messages
        • Produce and Consume Binary Messages
        • Inspect Topic Metadata
      • Features
      • Installation
      • Deployment
      • Development
      • Requirements
      • Contribute
      • License
    • Changelog
      • 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
      • Topics
      • Partitions
      • Consumers
      • Brokers
    • Configuration Options
    • 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
  • Camus
    • Camus
      • Key Features
      • Quickstart
      • Installation
      • Deployment
      • Development
      • Requirements
      • Contribute
      • License
    • Changelog
      • Version 3.1.1
      • Version 3.1.0
      • Version 3.0.0
      • Version 2.0.1
      • Version 2.0.0
    • Configuration Options
      • Schema Registry Configuration
      • Camus Job Configuration
      • Kafka Configuration
      • Example Configuration
    • Design
    • Operations
      • Important Configuration Options
  • Confluent Proactive Support
    • 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
  • Previous Versions
  • Docs
  • Kafka Connect »
  • Bundled Connectors »
  • Confluent Replicator
  • View page source

Confluent Replicator¶

Contents:

  • Confluent Replicator
    • Features
    • Requirements
    • Quickstart
      • Start the target cluster
      • Start the source cluster
      • Configure and run Replicator
    • Topic Renaming
    • Periodic Metadata Updates
    • Security
  • 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

© Copyright 2019, 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 Aug 29, 2019.

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