Confluent Confluent
Documentation Confluent Platform for Apache Flink
Confluent Developer Marketplace Get started
Home Confluent Cloud Confluent Platform Connectors Clients

Confluent Platform for Apache Flink

  • Overview
  • Installation and Upgrade
  • Get Started
  • Architecture and Features
  • Configure Components and Access Control
  • Deploy and Manage Flink Jobs
  • Disaster Recovery
  • Confluent Platform for Apache Flink Operations
  • How-to Guides
  • FAQ
  • Get Help
  • What's New
Ask the community Confluent Support Portal Last published: Jul 15, 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
  • Overview
  • Installation and Upgrade
    • Overview
    • Versions and Interoperability
    • Install with Helm
    • Install on OpenShift
    • Build Container Images
    • Configure Authentication
    • Configure Authorization
    • Configure Embedded MDS
    • Configure the CMF UI
    • Configure Storage
    • Configure Encryption
    • Configure SQL Statements
    • Upgrade
  • Get Started
    • Overview
    • Get Started with Applications
    • Get Started with Statements
  • Architecture and Features
    • Overview
    • Understand Flink
    • Confluent Manager for Apache Flink
  • Configure Components and Access Control
    • Overview
    • Manage Multiple Kubernetes Clusters (Multi-Cluster)
    • Manage Environments
    • Manage Environment Catalogs
    • Manage Kafka Catalogs and Databases
    • Manage Compute Pools
    • Manage Artifacts
    • Configure Access Control
  • Deploy and Manage Flink Jobs
    • Overview
    • Applications
      • Overview
      • Create Applications
      • Manage Applications
      • Application Instances
      • Events
      • Package Flink Jobs
      • Package PyFlink Jobs
      • Package Python UDFs with the Java Table API
      • Run Flink Agents
      • Supported Features
    • SQL Statements
      • Overview
      • Create Statements
      • Manage Statements
      • Table Operations
      • User-Defined Functions
      • Custom Connectors
      • Examples
        • Set Up Your Environment
        • Redact a Column with a UDF
        • Round-Trip an Iceberg Table
        • Read CSV from Object Storage
        • Use the MongoDB Connector
      • Use Interactive Shell
      • Forecast
      • Anomaly Detection
      • Features and Support
    • Manage Savepoints
    • Job Configuration
      • Overview
      • Checkpointing
      • Logging
      • Metrics
      • Security
  • Disaster Recovery
  • Confluent Platform for Apache Flink Operations
    • Overview
    • Use the CMF UI
    • Use REST APIs
    • Use CLI Operations
    • Use the MCP Server
    • Use Confluent for Kubernetes
  • How-to Guides
    • Overview
    • Checkpoint to S3
  • FAQ
  • Get Help
  • What's New
Confluent Platform for Apache Flink
Get started
    Home Confluent Cloud Confluent Platform Connectors Clients
    • Overview
    • Installation and Upgrade
      • Overview
      • Versions and Interoperability
      • Install with Helm
      • Install on OpenShift
      • Build Container Images
      • Configure Authentication
      • Configure Authorization
      • Configure Embedded MDS
      • Configure the CMF UI
      • Configure Storage
      • Configure Encryption
      • Configure SQL Statements
      • Upgrade
    • Get Started
      • Overview
      • Get Started with Applications
      • Get Started with Statements
    • Architecture and Features
      • Overview
      • Understand Flink
      • Confluent Manager for Apache Flink
    • Configure Components and Access Control
      • Overview
      • Manage Multiple Kubernetes Clusters (Multi-Cluster)
      • Manage Environments
      • Manage Environment Catalogs
      • Manage Kafka Catalogs and Databases
      • Manage Compute Pools
      • Manage Artifacts
      • Configure Access Control
    • Deploy and Manage Flink Jobs
      • Overview
      • Applications
        • Overview
        • Create Applications
        • Manage Applications
        • Application Instances
        • Events
        • Package Flink Jobs
        • Package PyFlink Jobs
        • Package Python UDFs with the Java Table API
        • Run Flink Agents
        • Supported Features
      • SQL Statements
        • Overview
        • Create Statements
        • Manage Statements
        • Table Operations
        • User-Defined Functions
        • Custom Connectors
        • Examples
          • Set Up Your Environment
          • Redact a Column with a UDF
          • Round-Trip an Iceberg Table
          • Read CSV from Object Storage
          • Use the MongoDB Connector
        • Use Interactive Shell
        • Forecast
        • Anomaly Detection
        • Features and Support
      • Manage Savepoints
      • Job Configuration
        • Overview
        • Checkpointing
        • Logging
        • Metrics
        • Security
    • Disaster Recovery
    • Confluent Platform for Apache Flink Operations
      • Overview
      • Use the CMF UI
      • Use REST APIs
      • Use CLI Operations
      • Use the MCP Server
      • Use Confluent for Kubernetes
    • How-to Guides
      • Overview
      • Checkpoint to S3
    • FAQ
    • Get Help
    • What's New