Confluent Confluent
Documentation Cluster Linking on Confluent Platform
Confluent Developer Marketplace Get started
Home Confluent Cloud Confluent Platform Connectors Clients
  1. Home
  2. Platform
  3. Deploy Confluent Platform in a Multi-Datacenter Environment
  4. Cluster Linking on Confluent Platform

Cluster Linking on Confluent Platform

  • Share Data Across Topics
  • Link Hybrid Cloud and Bridge-to-Cloud Clusters
  • Migrate Data
Ask the community Confluent Support Portal Last published: Aug 20, 2026
Terms & Conditions | Privacy Policy | Do Not Sell My Information | Modern Slavery Policy | Cookie Settings | Feedback

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

Table of contents

CONFLUENT PLATFORM

  • Overview
  • Get Started
    • Platform Overview
    • Quick Start
    • Learn More About Confluent and Kafka
    • Tutorial: Set Up a Multi-Broker Cluster
    • Scripted Confluent Platform Demo
      • Overview
      • Deploy Confluent Platform Environment
      • Deploy Hybrid Confluent Platform and Cloud Environment
      • Troubleshoot and Stop the Demo
    • Use Docs with AI Tools
  • Install and Upgrade
    • Overview
    • System Requirements
    • Supported Versions and Interoperability
    • Install Manually
      • ZIP and TAR
      • Ubuntu and Debian
      • RHEL, CentOS, Rocky, & Amazon Linux
      • Docker
        • Install
        • Configure
        • Image Reference
        • Security
        • Developer Guide
      • Configure Automatic Startup and Monitoring
    • Deploy with Ansible Playbooks
    • Deploy with Confluent for Kubernetes
    • License
    • Upgrade
      • Overview
      • Upgrade the Operating System
      • Confluent Platform Upgrade Procedure
    • Installation Packages
    • Migrate to Confluent Platform
    • Migrate to and from Confluent Server
    • Migrate from Confluent Server to Confluent Kafka
    • Migrate from ZooKeeper to KRaft
    • Installation FAQ
  • Build Client Applications
    • Overview
    • Configure Clients
      • Consumer
      • Share Consumers
      • Producer
      • Schemas, Serializers, and Deserializers
      • Configuration Properties
    • Client Guides
      • Python
      • .NET Client
      • JavaScript Client
      • Go Client
      • C++ Client
      • Java Client
    • Client Examples
      • Overview
      • Python Client
      • .NET Client
      • JavaScript Client
      • Go Client
      • C++ Client
      • Java
      • Spring Boot
      • KafkaProducer
      • REST
      • Clojure
      • Groovy
      • Kafka Connect Datagen
      • kafkacat
      • Kotlin
      • Ruby
      • Rust
      • Scala
    • Kafka Client APIs for Confluent Platform
      • Python Client API
      • .NET Client API
      • JavaScript Client API
      • Go Client API
      • C++ Client API
      • Java Client API
    • Deprecated Client APIs
    • Confluent Plugin for JetBrains IDEs
    • VS Code Extension
      • Overview
      • Quick Start
      • Connect to a Kafka Cluster
    • MQTT Proxy for Confluent Platform
      • Overview
      • Secure Communication
      • Configure
  • Build Kafka Streams Applications
    • Overview
    • Quick Start
    • Streams API
    • Tutorial: Streaming Application Development Basics on Confluent Platform
    • Connect Streams to Confluent Cloud
    • Concepts
    • Architecture
    • Examples
    • Developer Guide
      • Overview
      • Write a Streams Application
      • Configure
      • Run a Streams Application
      • Test
      • Domain Specific Language
      • Name Domain Specific Language Topologies
      • Optimize Topologies
      • Processor API
      • Data Types and Serialization
      • Interactive Queries
      • Memory
      • Manage Application Topics
      • Security
      • Reset Streams Applications
      • Streams Groups Tool
      • Streams Rebalance Protocol
    • Build Pipeline with Connect and Streams
    • Operations
      • Metrics
      • Monitor
      • Plan and Size
    • Upgrade
    • Frequently Asked Questions
    • Javadocs
    • ksqlDB
      • Overview
      • Quick Start
      • Install
      • Operate
      • Upgrade
      • Concepts
        • Overview
        • Kafka Primer
        • Connectors
        • Events
        • Functions
        • Lambda Functions
        • Materialized Views
        • Queries
        • Streams
        • Stream Processing
        • Tables
        • Time and Windows in ksqlDB Queries
      • How-to Guides
        • Overview
        • Control the Case of Identifiers
        • Convert a Changelog to a Table
        • Create a User-defined Function
        • Manage Connectors
        • Query Structured Data
        • Test an Application
        • Update a Running Persistent Query
        • Use Variables in SQL Statements
        • Use a Custom Timestamp Column
        • Use Lambda Functions
      • Develop Applications
        • Overview
        • Joins
          • Overview
          • Join Streams and Tables
          • Partition Data
          • Synthetic Keys
        • Reference
          • Overview
          • Aggregate Functions
          • ALTER SYSTEM
          • ASSERT SCHEMA
          • ASSERT TOPIC
          • CREATE CONNECTOR
          • CREATE STREAM AS SELECT
          • CREATE STREAM
          • CREATE TABLE AS SELECT
          • CREATE TABLE
          • CREATE TYPE
          • DEFINE
          • DESCRIBE CONNECTOR
          • DESCRIBE FUNCTION
          • DESCRIBE
          • DROP CONNECTOR
          • DROP STREAM
          • DROP TABLE
          • DROP TYPE
          • EXPLAIN
          • Functions
          • INSERT INTO
          • INSERT VALUES
          • Operators
          • PAUSE
          • PRINT
          • Quick Reference
          • RESUME
          • RUN SCRIPT
          • Scalar Functions
          • SELECT (Pull Query)
          • SELECT (Push Query)
          • SHOW CONNECTORS
          • SHOW FUNCTIONS
          • SHOW PROPERTIES
          • SHOW QUERIES
          • SHOW STREAMS
          • SHOW TABLES
          • SHOW TOPICS
          • SHOW TYPES
          • SHOW VARIABLES
          • SPOOL
          • Table Functions
          • TERMINATE
          • Type Coercion
          • UNDEFINE
        • REST API
          • Overview
          • REST API Reference
          • Cluster Status
          • Info
          • Is Valid Property
          • Run SQL statements
          • Query a Stream
          • Get statement status
          • Streaming API endpoint
          • Terminate a cluster
        • Java Client
      • Operate and Deploy
        • Overview
        • Installation
          • Overview
          • Install ksqlDB
          • Install with Docker Containers
          • Check Server Health
          • Configure ksqlDB Server
          • Configure Security
          • Connect the CLI to a Server
          • Integrate with Schema Registry
          • Upgrade ksqlDB
          • Legacy Documentation
        • ksqlDB Architecture
        • Capacity Planning
        • Changelog
        • Processing Guarantees
        • High Availability
        • High Availability Pull Queries
        • KSQL versus ksqlDB
        • Logging
        • Manage Metadata Schemas
        • Monitoring
        • Performance Guidelines
        • Schema Inference With ID
        • Schema Inference
      • Reference
        • Overview
        • SQL
          • Overview
          • SQL Keywords and Operators
          • Use DDL to Structure Data
          • Data Types
          • Syntax and Lexical Structure
          • Time Units and Formats
        • Metrics
        • Migrations Tool
        • Processing Log
        • Serialization Formats
        • Server Configuration Parameters
        • User-defined functions (UDFs)
      • Run ksqlDB in Confluent Cloud
      • Connect Local ksqlDB to Confluent Cloud
      • Connect ksqlDB to Control Center
      • Secure ksqlDB with RBAC
      • Frequently Asked Questions
      • Troubleshoot
      • Tutorials and Examples
        • Overview
        • How-to Guides
          • Overview
          • Control the Case of Identifiers
          • Convert a Changelog to a Table
          • Create a User-defined Function
          • Manage Connectors
          • Query Structured Data
          • Test an Application
          • Update a Running Persistent Query
          • Use Variables in SQL Statements
          • Use a Custom Timestamp Column
          • Use Lambda Functions
        • Materialized View
        • Streaming ETL Pipeline
        • Event-Driven Microservice
        • Build Clickstream Data Analysis Pipeline
  • Confluent Private Cloud
    • Overview
    • Confluent Private Cloud Gateway
    • Intelligent Replication
      • Overview
      • Enable Intelligent Replication
      • Monitor Intelligent Replication
      • Configure Intelligent Replication
      • Troubleshoot Intelligent Replication
    • Release Notes for Confluent Private Cloud
  • Confluent REST Proxy for Kafka
    • Overview
    • Quick Start
    • API Reference
    • Production Deployment
      • Overview
      • Deploy REST Proxy for Confluent Server
        • Configure REST Admin APIs
        • Configure Security
      • Deploy a Standalone REST Proxy node
        • Overview
        • Configure
        • Monitor
        • Secure REST Proxy
    • Connect to Confluent Cloud
  • Process Data With Flink
  • Connect to External Services
    • Overview
    • Get Started
    • Connectors
    • Confluent Marketplace
      • Overview
      • Component Archive Specification
      • Contribute
    • Connect on z/OS for Confluent Platform
    • Install
    • License
    • Supported
      • Supported Self-Managed Connectors for Confluent Platform
      • Supported Connector Versions in Confluent Platform 8.3
    • Preview
    • Configure
    • Monitor
    • Logging
    • Connect to Confluent Cloud
    • Developer Guide
    • Tutorial: Moving Data In and Out of Kafka
    • Reference
      • Kafka Connect Javadocs for Confluent Platform
      • REST interface
      • Kafka Connect Worker Configuration Properties for Confluent Platform
      • Connector Configuration Properties for Confluent Platform
      • Kafka Connect Cluster Sizing for Confluent Platform connectors
    • Transform
    • Custom Transforms
    • Security
      • Kafka Connect Security Basics for Confluent Platform
      • Kafka Connect and RBAC for Confluent Platform
        • Get Started With RBAC and Kafka Connect for Confluent Platform
        • Configure RBAC for a Connect Cluster for Confluent Platform
        • Configure RBAC for a Connect Worker for Confluent Platform
        • RBAC for self-managed connectors for Confluent Platform
        • Connect Secret Registry for Confluent Platform
        • Example Connect role-binding sequence for Confluent Platform
      • Manage Client-Side Encryption in Confluent Cloud for Self-Managed Connectors
      • Manage Client-Side Encryption in Confluent Platform for Self-Managed Connectors
      • Manage CSFLE for partner-managed connectors
    • Design
    • Add Connectors and Software
    • Install Community Connectors
    • Upgrade
    • Troubleshoot
    • FileStream Connectors
    • FAQ
  • Manage Schema Registry and Govern Data Streams
    • Overview
    • Get Started with Schema Registry Tutorial
    • Install and Configure
      • Install
      • Configure Schema Registry
      • Configure Clients to Schema Registry
      • Deploy in Production
      • Deployment Architectures
      • Use Schema Registry to Migrate Schemas in Confluent Platform
    • Fundamentals
      • Key Concepts
      • Schema Evolution and Compatibility
      • Schema Formats
        • Serializers and Deserializers Overview
        • Avro
        • Protobuf
        • JSON Schema
      • Data Contracts
    • Manage Schemas
      • Work with Schemas in Control Center
      • Schema Contexts
      • Schema Linking
      • Validate Schema IDs
      • Monitor
      • Delete Schemas
      • Integrate Schemas from Connectors
    • Security
      • Overview
      • Configure Role-Based Access Control
      • Configure OAuth
      • Schema Registry Security Plugin
        • Overview
        • Install
        • Schema Registry Authorization
          • Operation and Resource Support
          • Role-Based Access Control
          • ACL Authorizer
          • Topic ACL Authorizer
      • Passwordless authentication for Schema Registry
    • Reference
      • Overview
      • Maven Plugin
      • API
      • API Examples
    • FAQ
  • Manage Security
    • Overview
    • Deployment Profiles
    • Compliance
      • Overview
      • Audit Logs
        • Audit Logs Concepts
        • Auditable Events
        • Configure Audit Logs Using Confluent CLI
        • Configure MDS to Manage Centralized Audit Logs
        • MDS API Audit Log Configuration
        • Use Properties Files to Configure Audit Logs in Confluent Platform
      • Manage Secrets
        • Overview
        • Tutorial: Protect Secrets
    • Authenticate
      • Overview
      • Mutual TLS
        • Overview
        • Use Principal Mapping
      • OAuth/OIDC
        • Overview
        • Configure Microsoft Entra ID as Your Identity Provider
        • Claim Validation for OAuth JWT tokens
        • OAuth/OIDC Service-to-Service Authentication
        • Configure Confluent Server Brokers
        • Configure Confluent Schema Registry
        • Configure Metadata Service
        • Configure Kafka Connect
        • Configure Confluent Control Center
        • Configure REST Proxy
        • Configure Truststores for TLS Handshake with Identity Providers
        • Migrate from mTLS to OAuth Authentication
        • Use OAuth with ksqlDB
      • Multi-Protocol Authentication
        • Overview
        • Use AuthenticationHandler Class
      • REST Proxy
        • Overview
        • Principal Propagation for mTLS
      • SSO for Confluent Control Center
        • Overview
        • Configure OIDC SSO for Control Center
        • Configure OIDC SSO for Confluent CLI
        • Troubleshoot
      • HTTP Basic Authentication
        • Overview
      • SASL
        • Overview
        • SASL/GSSAPI (Kerberos)
          • Overview
        • SASL/OAUTHBEARER
          • Overview
          • Configure Confluent Server Brokers
          • Configure Clients
          • Configure UAMI
          • Configure AWS IAM Java Client Plugin
          • Configure AWS IAM Python Client Plugin
          • Configure AWS IAM .NET Client Plugin
        • SASL/PLAIN
          • Overview
        • SASL/SCRAM
          • Overview
      • LDAP
        • Overview
        • Configure Kafka Clients
      • Delegation Tokens
        • Overview
    • Authorize
      • Overview
      • Access Control Lists
        • Overview
        • Manage ACLs
      • Role-Based Access Control
        • Overview
        • Quick Start
        • Predefined RBAC Roles
        • Cluster Identifiers
        • Example of Enabling RBAC
        • Enable RBAC on Running Cluster
        • Use mTLS with RBAC
        • Configure mTLS with RBAC
        • Deployment Patterns for mTLS with RBAC
        • Client Flow for OAuth-OIDC using RBAC
        • Migrate LDAP to OAuth for RBAC
        • Migrate LDAP to mTLS for RBAC
        • RBAC using REST API
        • Use Centralized ACLs with MDS for Authorization
        • Request Forwarding with mTLS RBAC
        • Deploy Secure ksqlDB with RBAC
        • Metadata API
      • LDAP Group-Based Authorization
        • Configure LDAP Group-Based Authorization
        • LDAP Configuration Reference
        • Tutorial: Group-Based Authorization Using LDAP
        • Configure Confluent Server Authorizer in Confluent Platform
    • Protect Data
      • Overview
      • TLS Encryption
      • Client-Side Field Level Encryption
        • Overview
        • Quick Start
        • Use Client-side Field Level Encryption
        • Configuration Settings
        • Manage Encryption Keys
        • Implement a Custom KMS Driver
        • Code examples
        • Troubleshoot
        • FAQ
      • Client-Side Payload Encryption
      • Redact Confluent Logs
    • Configure Security Properties using Prefixes
    • Secure Components
      • Overview
      • Schema Registry
      • Kafka Connect
      • KRaft Security
      • ksqlDB RBAC
      • REST Proxy
        • Deploy Secure Standalone REST Proxy in Confluent Platform
        • REST Proxy Security Plugins in Confluent Platform
    • Enable Security for a Cluster
    • Add Security to Running Clusters
    • Configure Confluent Server Authorizer
    • Security Management Tools
      • Ansible Playbooks for Confluent Platform
      • Deploy Secure Confluent Platform Docker Images
    • Cluster Registry
  • Deploy in Multi-Datacenter Environment
    • Overview
    • Multi-Datacenter Architectures on Confluent Platform
    • Cluster Linking on Confluent Platform
      • Overview
      • Tutorials
        • Share Data Across Topics
        • Link Hybrid Cloud and Bridge-to-Cloud Clusters
        • Migrate Data
      • Manage
        • Manage Mirror Topics
        • Configure
        • Command Reference
        • Monitor
        • Security
      • FAQ
      • Troubleshooting
    • Multi-Region Clusters on Confluent Platform
      • Overview
      • Tutorial: Multi-Region Clusters
      • Tutorial: Move Active-Passive to Multi-Region
    • Replicate Topics Across Kafka Clusters in Confluent Platform
      • Overview
      • Example: Active-active Multi-Datacenter
      • Tutorial: Replicate Data Across Clusters
      • Tutorial: Run as an Executable or Connector
      • Configure
      • Verify Configuration
      • Tune
      • Monitor
      • Configure for Cross-Cluster Failover
      • Migrate from MirrorMaker to Replicator
      • Replicator Schema Translation Example for Confluent Platform
  • Configure and Manage
    • Overview
    • Share Groups
    • Configuration Reference
      • Overview
      • Configure Brokers and Controllers
      • Configure Topics
      • Configure Consumers
      • Configure Producers
      • Configure Connect
        • Overview
        • Configure Sink Connectors
        • Configure Source Connectors
      • Configure AdminClient
      • Configure Licenses
      • Configure Streams
    • CLI Tools for Use with Confluent Platform
      • Overview
      • Bundled CLI Tools
      • Confluent CLI
      • Generate Diagnostics
      • Check Clusters for KRaft Migration
      • kcat (formerly kafkacat) Utility
    • Change Configurations Without Restart
    • Manage Clusters
      • Overview
      • Cluster Metadata Management
        • Overview
        • KRaft Overview
        • Configure KRaft
        • Find ZooKeeper Resources
      • Manage Self-Balancing Clusters
        • Overview
        • Tutorial: Adding and Removing Brokers
        • Configure
        • Use JBOD
        • Performance and Resource Usage
      • Auto Data Balancing
        • Overview
        • Quick Start
        • Tutorial: Add and Remove Brokers
        • Configure
      • Tiered Storage
    • Metadata Service (MDS) in Confluent Platform
      • Configure MDS
      • Configure Communication with MDS over TLS
      • Configure mTLS Authentication and RBAC for Kafka Brokers
      • Configure Kerberos Authentication for Brokers Running MDS
      • Configure LDAP Authentication
      • Configure LDAP Group-Based Authorization for MDS
      • MDS as token issuer
      • Metadata Service Configuration Settings
      • MDS File-Based Authentication for Confluent Platform
    • Docker Operations for Confluent Platform
      • Overview
      • Monitor and Track Metrics Using JMX
      • Configure Logs
      • Mount External Volumes
      • Configure a Multi-Node Environment
      • Configure Share Groups
    • Run Kafka in Production
    • Configure Kafka Listeners
    • Production Best Practices
    • Manage Topics
    • Cordon Brokers and Log Directories
    • Deprecations
  • Manage Hybrid Environments with USM
    • Overview
    • Get Started with USM
    • Quick Start: USM with CFK
    • USM Agent Operations
    • USM Agent Network Configuration
    • USM Agent Metrics and Metadata Reference
    • Schema Registry in Hybrid Setup
    • Configure Clients
    • Configure Kafka Streams Applications
    • USM Agent Release Notes
  • Monitor with Control Center
  • Monitor
    • Logging
    • Monitor with JMX
      • Overview
      • Configure JMX
      • Broker and Controller Metrics
      • Log and Network Metrics
      • Group Coordinator Metrics
      • Producer Metrics
      • Consumer Metrics
      • Share Consumer Metrics
      • Security Metrics
    • Monitor with Metrics Reporter
    • Monitor Consumer Lag
    • Monitor with Health+
      • Overview
      • Enable
      • Intelligent Alerts
      • Monitor Using Dashboard
      • Configure Telemetry Reporter
      • Telemetry Reporter Metrics Reference
      • FAQ
  • Confluent CLI
  • Release Notes
    • Release Notes
    • Changelogs
    • Documentation Archive
  • APIs and Javadocs
    • Overview
    • Kafka API and Javadocs for Confluent Platform
      • Kafka Java Client APIs
      • Kafka Producer Java API
      • Kafka Consumer Java API
      • Kafka AdminClient Java API
      • Kafka Common Java API
      • Kafka Streams Java API
      • Kafka Connect Java API
    • Client APIs
      • Python Client API
      • .NET Client API
      • JavaScript Client API
      • Go Client API
      • C++ Client API
      • Java Client API
    • Confluent APIs for Confluent Platform
      • Overview
      • Confluent REST Proxy API
      • Connect REST API
      • Flink REST API
      • Schema Registry API
      • ksqlDB REST API
      • Metadata API
  • Glossary
Cluster Linking on Confluent Platform
Get started
    Home Confluent Cloud Confluent Platform Connectors Clients

    CONFLUENT PLATFORM

    • Overview
    • Get Started
      • Platform Overview
      • Quick Start
      • Learn More About Confluent and Kafka
      • Tutorial: Set Up a Multi-Broker Cluster
      • Scripted Confluent Platform Demo
        • Overview
        • Deploy Confluent Platform Environment
        • Deploy Hybrid Confluent Platform and Cloud Environment
        • Troubleshoot and Stop the Demo
      • Use Docs with AI Tools
    • Install and Upgrade
      • Overview
      • System Requirements
      • Supported Versions and Interoperability
      • Install Manually
        • ZIP and TAR
        • Ubuntu and Debian
        • RHEL, CentOS, Rocky, & Amazon Linux
        • Docker
          • Install
          • Configure
          • Image Reference
          • Security
          • Developer Guide
        • Configure Automatic Startup and Monitoring
      • Deploy with Ansible Playbooks
      • Deploy with Confluent for Kubernetes
      • License
      • Upgrade
        • Overview
        • Upgrade the Operating System
        • Confluent Platform Upgrade Procedure
      • Installation Packages
      • Migrate to Confluent Platform
      • Migrate to and from Confluent Server
      • Migrate from Confluent Server to Confluent Kafka
      • Migrate from ZooKeeper to KRaft
      • Installation FAQ
    • Build Client Applications
      • Overview
      • Configure Clients
        • Consumer
        • Share Consumers
        • Producer
        • Schemas, Serializers, and Deserializers
        • Configuration Properties
      • Client Guides
        • Python
        • .NET Client
        • JavaScript Client
        • Go Client
        • C++ Client
        • Java Client
      • Client Examples
        • Overview
        • Python Client
        • .NET Client
        • JavaScript Client
        • Go Client
        • C++ Client
        • Java
        • Spring Boot
        • KafkaProducer
        • REST
        • Clojure
        • Groovy
        • Kafka Connect Datagen
        • kafkacat
        • Kotlin
        • Ruby
        • Rust
        • Scala
      • Kafka Client APIs for Confluent Platform
        • Python Client API
        • .NET Client API
        • JavaScript Client API
        • Go Client API
        • C++ Client API
        • Java Client API
      • Deprecated Client APIs
      • Confluent Plugin for JetBrains IDEs
      • VS Code Extension
        • Overview
        • Quick Start
        • Connect to a Kafka Cluster
      • MQTT Proxy for Confluent Platform
        • Overview
        • Secure Communication
        • Configure
    • Build Kafka Streams Applications
      • Overview
      • Quick Start
      • Streams API
      • Tutorial: Streaming Application Development Basics on Confluent Platform
      • Connect Streams to Confluent Cloud
      • Concepts
      • Architecture
      • Examples
      • Developer Guide
        • Overview
        • Write a Streams Application
        • Configure
        • Run a Streams Application
        • Test
        • Domain Specific Language
        • Name Domain Specific Language Topologies
        • Optimize Topologies
        • Processor API
        • Data Types and Serialization
        • Interactive Queries
        • Memory
        • Manage Application Topics
        • Security
        • Reset Streams Applications
        • Streams Groups Tool
        • Streams Rebalance Protocol
      • Build Pipeline with Connect and Streams
      • Operations
        • Metrics
        • Monitor
        • Plan and Size
      • Upgrade
      • Frequently Asked Questions
      • Javadocs
      • ksqlDB
        • Overview
        • Quick Start
        • Install
        • Operate
        • Upgrade
        • Concepts
          • Overview
          • Kafka Primer
          • Connectors
          • Events
          • Functions
          • Lambda Functions
          • Materialized Views
          • Queries
          • Streams
          • Stream Processing
          • Tables
          • Time and Windows in ksqlDB Queries
        • How-to Guides
          • Overview
          • Control the Case of Identifiers
          • Convert a Changelog to a Table
          • Create a User-defined Function
          • Manage Connectors
          • Query Structured Data
          • Test an Application
          • Update a Running Persistent Query
          • Use Variables in SQL Statements
          • Use a Custom Timestamp Column
          • Use Lambda Functions
        • Develop Applications
          • Overview
          • Joins
            • Overview
            • Join Streams and Tables
            • Partition Data
            • Synthetic Keys
          • Reference
            • Overview
            • Aggregate Functions
            • ALTER SYSTEM
            • ASSERT SCHEMA
            • ASSERT TOPIC
            • CREATE CONNECTOR
            • CREATE STREAM AS SELECT
            • CREATE STREAM
            • CREATE TABLE AS SELECT
            • CREATE TABLE
            • CREATE TYPE
            • DEFINE
            • DESCRIBE CONNECTOR
            • DESCRIBE FUNCTION
            • DESCRIBE
            • DROP CONNECTOR
            • DROP STREAM
            • DROP TABLE
            • DROP TYPE
            • EXPLAIN
            • Functions
            • INSERT INTO
            • INSERT VALUES
            • Operators
            • PAUSE
            • PRINT
            • Quick Reference
            • RESUME
            • RUN SCRIPT
            • Scalar Functions
            • SELECT (Pull Query)
            • SELECT (Push Query)
            • SHOW CONNECTORS
            • SHOW FUNCTIONS
            • SHOW PROPERTIES
            • SHOW QUERIES
            • SHOW STREAMS
            • SHOW TABLES
            • SHOW TOPICS
            • SHOW TYPES
            • SHOW VARIABLES
            • SPOOL
            • Table Functions
            • TERMINATE
            • Type Coercion
            • UNDEFINE
          • REST API
            • Overview
            • REST API Reference
            • Cluster Status
            • Info
            • Is Valid Property
            • Run SQL statements
            • Query a Stream
            • Get statement status
            • Streaming API endpoint
            • Terminate a cluster
          • Java Client
        • Operate and Deploy
          • Overview
          • Installation
            • Overview
            • Install ksqlDB
            • Install with Docker Containers
            • Check Server Health
            • Configure ksqlDB Server
            • Configure Security
            • Connect the CLI to a Server
            • Integrate with Schema Registry
            • Upgrade ksqlDB
            • Legacy Documentation
          • ksqlDB Architecture
          • Capacity Planning
          • Changelog
          • Processing Guarantees
          • High Availability
          • High Availability Pull Queries
          • KSQL versus ksqlDB
          • Logging
          • Manage Metadata Schemas
          • Monitoring
          • Performance Guidelines
          • Schema Inference With ID
          • Schema Inference
        • Reference
          • Overview
          • SQL
            • Overview
            • SQL Keywords and Operators
            • Use DDL to Structure Data
            • Data Types
            • Syntax and Lexical Structure
            • Time Units and Formats
          • Metrics
          • Migrations Tool
          • Processing Log
          • Serialization Formats
          • Server Configuration Parameters
          • User-defined functions (UDFs)
        • Run ksqlDB in Confluent Cloud
        • Connect Local ksqlDB to Confluent Cloud
        • Connect ksqlDB to Control Center
        • Secure ksqlDB with RBAC
        • Frequently Asked Questions
        • Troubleshoot
        • Tutorials and Examples
          • Overview
          • How-to Guides
            • Overview
            • Control the Case of Identifiers
            • Convert a Changelog to a Table
            • Create a User-defined Function
            • Manage Connectors
            • Query Structured Data
            • Test an Application
            • Update a Running Persistent Query
            • Use Variables in SQL Statements
            • Use a Custom Timestamp Column
            • Use Lambda Functions
          • Materialized View
          • Streaming ETL Pipeline
          • Event-Driven Microservice
          • Build Clickstream Data Analysis Pipeline
    • Confluent Private Cloud
      • Overview
      • Confluent Private Cloud Gateway
      • Intelligent Replication
        • Overview
        • Enable Intelligent Replication
        • Monitor Intelligent Replication
        • Configure Intelligent Replication
        • Troubleshoot Intelligent Replication
      • Release Notes for Confluent Private Cloud
    • Confluent REST Proxy for Kafka
      • Overview
      • Quick Start
      • API Reference
      • Production Deployment
        • Overview
        • Deploy REST Proxy for Confluent Server
          • Configure REST Admin APIs
          • Configure Security
        • Deploy a Standalone REST Proxy node
          • Overview
          • Configure
          • Monitor
          • Secure REST Proxy
      • Connect to Confluent Cloud
    • Process Data With Flink
    • Connect to External Services
      • Overview
      • Get Started
      • Connectors
      • Confluent Marketplace
        • Overview
        • Component Archive Specification
        • Contribute
      • Connect on z/OS for Confluent Platform
      • Install
      • License
      • Supported
        • Supported Self-Managed Connectors for Confluent Platform
        • Supported Connector Versions in Confluent Platform 8.3
      • Preview
      • Configure
      • Monitor
      • Logging
      • Connect to Confluent Cloud
      • Developer Guide
      • Tutorial: Moving Data In and Out of Kafka
      • Reference
        • Kafka Connect Javadocs for Confluent Platform
        • REST interface
        • Kafka Connect Worker Configuration Properties for Confluent Platform
        • Connector Configuration Properties for Confluent Platform
        • Kafka Connect Cluster Sizing for Confluent Platform connectors
      • Transform
      • Custom Transforms
      • Security
        • Kafka Connect Security Basics for Confluent Platform
        • Kafka Connect and RBAC for Confluent Platform
          • Get Started With RBAC and Kafka Connect for Confluent Platform
          • Configure RBAC for a Connect Cluster for Confluent Platform
          • Configure RBAC for a Connect Worker for Confluent Platform
          • RBAC for self-managed connectors for Confluent Platform
          • Connect Secret Registry for Confluent Platform
          • Example Connect role-binding sequence for Confluent Platform
        • Manage Client-Side Encryption in Confluent Cloud for Self-Managed Connectors
        • Manage Client-Side Encryption in Confluent Platform for Self-Managed Connectors
        • Manage CSFLE for partner-managed connectors
      • Design
      • Add Connectors and Software
      • Install Community Connectors
      • Upgrade
      • Troubleshoot
      • FileStream Connectors
      • FAQ
    • Manage Schema Registry and Govern Data Streams
      • Overview
      • Get Started with Schema Registry Tutorial
      • Install and Configure
        • Install
        • Configure Schema Registry
        • Configure Clients to Schema Registry
        • Deploy in Production
        • Deployment Architectures
        • Use Schema Registry to Migrate Schemas in Confluent Platform
      • Fundamentals
        • Key Concepts
        • Schema Evolution and Compatibility
        • Schema Formats
          • Serializers and Deserializers Overview
          • Avro
          • Protobuf
          • JSON Schema
        • Data Contracts
      • Manage Schemas
        • Work with Schemas in Control Center
        • Schema Contexts
        • Schema Linking
        • Validate Schema IDs
        • Monitor
        • Delete Schemas
        • Integrate Schemas from Connectors
      • Security
        • Overview
        • Configure Role-Based Access Control
        • Configure OAuth
        • Schema Registry Security Plugin
          • Overview
          • Install
          • Schema Registry Authorization
            • Operation and Resource Support
            • Role-Based Access Control
            • ACL Authorizer
            • Topic ACL Authorizer
        • Passwordless authentication for Schema Registry
      • Reference
        • Overview
        • Maven Plugin
        • API
        • API Examples
      • FAQ
    • Manage Security
      • Overview
      • Deployment Profiles
      • Compliance
        • Overview
        • Audit Logs
          • Audit Logs Concepts
          • Auditable Events
          • Configure Audit Logs Using Confluent CLI
          • Configure MDS to Manage Centralized Audit Logs
          • MDS API Audit Log Configuration
          • Use Properties Files to Configure Audit Logs in Confluent Platform
        • Manage Secrets
          • Overview
          • Tutorial: Protect Secrets
      • Authenticate
        • Overview
        • Mutual TLS
          • Overview
          • Use Principal Mapping
        • OAuth/OIDC
          • Overview
          • Configure Microsoft Entra ID as Your Identity Provider
          • Claim Validation for OAuth JWT tokens
          • OAuth/OIDC Service-to-Service Authentication
          • Configure Confluent Server Brokers
          • Configure Confluent Schema Registry
          • Configure Metadata Service
          • Configure Kafka Connect
          • Configure Confluent Control Center
          • Configure REST Proxy
          • Configure Truststores for TLS Handshake with Identity Providers
          • Migrate from mTLS to OAuth Authentication
          • Use OAuth with ksqlDB
        • Multi-Protocol Authentication
          • Overview
          • Use AuthenticationHandler Class
        • REST Proxy
          • Overview
          • Principal Propagation for mTLS
        • SSO for Confluent Control Center
          • Overview
          • Configure OIDC SSO for Control Center
          • Configure OIDC SSO for Confluent CLI
          • Troubleshoot
        • HTTP Basic Authentication
          • Overview
        • SASL
          • Overview
          • SASL/GSSAPI (Kerberos)
            • Overview
          • SASL/OAUTHBEARER
            • Overview
            • Configure Confluent Server Brokers
            • Configure Clients
            • Configure UAMI
            • Configure AWS IAM Java Client Plugin
            • Configure AWS IAM Python Client Plugin
            • Configure AWS IAM .NET Client Plugin
          • SASL/PLAIN
            • Overview
          • SASL/SCRAM
            • Overview
        • LDAP
          • Overview
          • Configure Kafka Clients
        • Delegation Tokens
          • Overview
      • Authorize
        • Overview
        • Access Control Lists
          • Overview
          • Manage ACLs
        • Role-Based Access Control
          • Overview
          • Quick Start
          • Predefined RBAC Roles
          • Cluster Identifiers
          • Example of Enabling RBAC
          • Enable RBAC on Running Cluster
          • Use mTLS with RBAC
          • Configure mTLS with RBAC
          • Deployment Patterns for mTLS with RBAC
          • Client Flow for OAuth-OIDC using RBAC
          • Migrate LDAP to OAuth for RBAC
          • Migrate LDAP to mTLS for RBAC
          • RBAC using REST API
          • Use Centralized ACLs with MDS for Authorization
          • Request Forwarding with mTLS RBAC
          • Deploy Secure ksqlDB with RBAC
          • Metadata API
        • LDAP Group-Based Authorization
          • Configure LDAP Group-Based Authorization
          • LDAP Configuration Reference
          • Tutorial: Group-Based Authorization Using LDAP
          • Configure Confluent Server Authorizer in Confluent Platform
      • Protect Data
        • Overview
        • TLS Encryption
        • Client-Side Field Level Encryption
          • Overview
          • Quick Start
          • Use Client-side Field Level Encryption
          • Configuration Settings
          • Manage Encryption Keys
          • Implement a Custom KMS Driver
          • Code examples
          • Troubleshoot
          • FAQ
        • Client-Side Payload Encryption
        • Redact Confluent Logs
      • Configure Security Properties using Prefixes
      • Secure Components
        • Overview
        • Schema Registry
        • Kafka Connect
        • KRaft Security
        • ksqlDB RBAC
        • REST Proxy
          • Deploy Secure Standalone REST Proxy in Confluent Platform
          • REST Proxy Security Plugins in Confluent Platform
      • Enable Security for a Cluster
      • Add Security to Running Clusters
      • Configure Confluent Server Authorizer
      • Security Management Tools
        • Ansible Playbooks for Confluent Platform
        • Deploy Secure Confluent Platform Docker Images
      • Cluster Registry
    • Deploy in Multi-Datacenter Environment
      • Overview
      • Multi-Datacenter Architectures on Confluent Platform
      • Cluster Linking on Confluent Platform
        • Overview
        • Tutorials
          • Share Data Across Topics
          • Link Hybrid Cloud and Bridge-to-Cloud Clusters
          • Migrate Data
        • Manage
          • Manage Mirror Topics
          • Configure
          • Command Reference
          • Monitor
          • Security
        • FAQ
        • Troubleshooting
      • Multi-Region Clusters on Confluent Platform
        • Overview
        • Tutorial: Multi-Region Clusters
        • Tutorial: Move Active-Passive to Multi-Region
      • Replicate Topics Across Kafka Clusters in Confluent Platform
        • Overview
        • Example: Active-active Multi-Datacenter
        • Tutorial: Replicate Data Across Clusters
        • Tutorial: Run as an Executable or Connector
        • Configure
        • Verify Configuration
        • Tune
        • Monitor
        • Configure for Cross-Cluster Failover
        • Migrate from MirrorMaker to Replicator
        • Replicator Schema Translation Example for Confluent Platform
    • Configure and Manage
      • Overview
      • Share Groups
      • Configuration Reference
        • Overview
        • Configure Brokers and Controllers
        • Configure Topics
        • Configure Consumers
        • Configure Producers
        • Configure Connect
          • Overview
          • Configure Sink Connectors
          • Configure Source Connectors
        • Configure AdminClient
        • Configure Licenses
        • Configure Streams
      • CLI Tools for Use with Confluent Platform
        • Overview
        • Bundled CLI Tools
        • Confluent CLI
        • Generate Diagnostics
        • Check Clusters for KRaft Migration
        • kcat (formerly kafkacat) Utility
      • Change Configurations Without Restart
      • Manage Clusters
        • Overview
        • Cluster Metadata Management
          • Overview
          • KRaft Overview
          • Configure KRaft
          • Find ZooKeeper Resources
        • Manage Self-Balancing Clusters
          • Overview
          • Tutorial: Adding and Removing Brokers
          • Configure
          • Use JBOD
          • Performance and Resource Usage
        • Auto Data Balancing
          • Overview
          • Quick Start
          • Tutorial: Add and Remove Brokers
          • Configure
        • Tiered Storage
      • Metadata Service (MDS) in Confluent Platform
        • Configure MDS
        • Configure Communication with MDS over TLS
        • Configure mTLS Authentication and RBAC for Kafka Brokers
        • Configure Kerberos Authentication for Brokers Running MDS
        • Configure LDAP Authentication
        • Configure LDAP Group-Based Authorization for MDS
        • MDS as token issuer
        • Metadata Service Configuration Settings
        • MDS File-Based Authentication for Confluent Platform
      • Docker Operations for Confluent Platform
        • Overview
        • Monitor and Track Metrics Using JMX
        • Configure Logs
        • Mount External Volumes
        • Configure a Multi-Node Environment
        • Configure Share Groups
      • Run Kafka in Production
      • Configure Kafka Listeners
      • Production Best Practices
      • Manage Topics
      • Cordon Brokers and Log Directories
      • Deprecations
    • Manage Hybrid Environments with USM
      • Overview
      • Get Started with USM
      • Quick Start: USM with CFK
      • USM Agent Operations
      • USM Agent Network Configuration
      • USM Agent Metrics and Metadata Reference
      • Schema Registry in Hybrid Setup
      • Configure Clients
      • Configure Kafka Streams Applications
      • USM Agent Release Notes
    • Monitor with Control Center
    • Monitor
      • Logging
      • Monitor with JMX
        • Overview
        • Configure JMX
        • Broker and Controller Metrics
        • Log and Network Metrics
        • Group Coordinator Metrics
        • Producer Metrics
        • Consumer Metrics
        • Share Consumer Metrics
        • Security Metrics
      • Monitor with Metrics Reporter
      • Monitor Consumer Lag
      • Monitor with Health+
        • Overview
        • Enable
        • Intelligent Alerts
        • Monitor Using Dashboard
        • Configure Telemetry Reporter
        • Telemetry Reporter Metrics Reference
        • FAQ
    • Confluent CLI
    • Release Notes
      • Release Notes
      • Changelogs
      • Documentation Archive
    • APIs and Javadocs
      • Overview
      • Kafka API and Javadocs for Confluent Platform
        • Kafka Java Client APIs
        • Kafka Producer Java API
        • Kafka Consumer Java API
        • Kafka AdminClient Java API
        • Kafka Common Java API
        • Kafka Streams Java API
        • Kafka Connect Java API
      • Client APIs
        • Python Client API
        • .NET Client API
        • JavaScript Client API
        • Go Client API
        • C++ Client API
        • Java Client API
      • Confluent APIs for Confluent Platform
        • Overview
        • Confluent REST Proxy API
        • Connect REST API
        • Flink REST API
        • Schema Registry API
        • ksqlDB REST API
        • Metadata API
    • Glossary