Deploy and Manage Confluent Manager for Apache Flink Applications

Confluent Manager for Apache Flink® (CMF) Applications are resources consisting of a Flink job, a Flink configuration, the specification of a Flink Kubernetes cluster, and status information. Flink jobs are packaged as Java JAR files and can be implemented in any Flink API, such as the DataStream API, Table API, or SQL.

Note

CMF’s SQL support provided by the Statement API is a more user-friendly way to run and manage Flink SQL queries. However, CMF Statements still have some limitations. Executing SQL queries wrapped in JAR files as CMF Applications provides all of the features of Flink SQL and provides an alternative to CMF Statements.

CMF executes an application by running its Flink job on a Flink cluster that is started in the Kubernetes namespace of the application’s environment. Every application runs on its own cluster, providing isolation between all applications.

CMF applications can be created and managed with CMF’s REST API, the Confluent CLI, and Confluent for Kubernetes. See the following topics to learn more about CMF applications: