Quick Start for Confluent Cloud

Confluent Cloud is a resilient, scalable, streaming data service based on Apache Kafka®, delivered as a fully managed service. Confluent Cloud has a web interface called the Cloud Console, a local command line interface, and REST APIs. You can manage cluster resources, settings, and billing with the Cloud Console. You can use the Confluent CLI and REST APIs to create and manage Kafka topics and more.

Get started for Free

Sign up for a Confluent Cloud trial and get $400 of free credit.

This quick start gets you up and running with Confluent Cloud using a Basic Kafka cluster.

• The first section shows how to use Confluent Cloud to create topics, and produce and consume data to and from the cluster.
• The second section walks you through how to use Confluent Cloud for Apache Flink® to run queries on the data using SQL syntax.

Prerequisites

• Access to Confluent Cloud. To get started for free, see Deploy Free Clusters on Confluent Cloud.
• Internet connectivity

The quick start workflows assume you already have a working Confluent Cloud environment, which incorporates a Stream Governance package at time of environment creation. Stream Governance will already be enabled in the environment as a prerequisite to this quick start. To learn more about Stream Governance packages, features, and environment setup workflows, see Manage Stream Governance Packages in Confluent Cloud.

Section 1: Create a cluster and add a topic

Follow the steps in this section to set up a Kafka cluster on Confluent Cloud and produce data to Kafka topics on the cluster.

Step 1: Create a Kafka cluster in Confluent Cloud

In this step, you create and launch a basic Kafka cluster inside your default environment.

Cloud ConsoleConfluent CLIConfluent Cloud APIs

1. Sign in to Confluent Cloud at https://confluent.cloud.

2. Click Add cluster.

3. On the Create cluster page, for the Basic cluster, select Begin configuration.

   

   This example creates a Basic Kafka cluster, which supports single zone availability. For information about other cluster types, see Kafka Cluster Types in Confluent Cloud.

4. On the Region/zones page, choose a cloud provider, region, and select single availability zone.

   

5. Select Continue.

   Note

   If you haven’t set up a payment method, you see the Set payment page. Enter payment method and select Review or select Skip payment.

6. Specify a cluster name, review the configuration and cost information, and then select Launch cluster.

   

Depending on the chosen cloud provider and other settings, it may take a few minutes to provision your cluster, but after the cluster has provisioned, the Cluster Overview page displays.

Now you can get started configuring apps and data on your new cluster.

Step 2: Create a Kafka topic

In this step, you create a users Kafka topic by using the Cloud Console. A topic is a unit of organization for a cluster, and is essentially an append-only log. For more information about topics, see What is Apache Kafka.

Cloud ConsoleConfluent CLIConfluent Cloud APIs

1. From the navigation menu, click Topics, and then click Create topic.

   

2. In the Topic name field, type “users” and then select Create with defaults.

   

The users topic is created on the Kafka cluster and is available for use by producers and consumers.

The success message may prompt you to take an action, but you should continue with Step 3: Create a sample producer.

Step 3: Create a sample producer

You can produce example data to your Kafka cluster by using the hosted Datagen Source Connector for Confluent Cloud.

Cloud ConsoleConfluent CLIConfluent Cloud APIs

1. From the navigation menu, select Connectors.

   To open Confluent Cloud at Connectors: https://confluent.cloud/go/connectors.

2. In the Search box, type “datagen”.

3. From the search results, select the Datagen Source connector.

   

   Tip

   If you see the Launch Sample Data box, select Additional configuration.

4. On the Topic selection pane, select the users topic you created in the previous section and then select Continue.

5. In the Kafka credentials pane, leave Global access selected, and click Generate API key & download. This creates an API key and secret that allows the connector to access your cluster, and downloads the key and secret to your computer.

   The key and secret are required for the connector and also for the Confluent CLI and ksqlDB CLI to access your cluster.

   Note

   An API key and associated secret apply to the active Kafka cluster. If you add a new cluster, you must create a new API key for producers and consumers on the new Kafka cluster. For more information, see Use API Keys to Authenticate to Confluent Cloud.

6. Enter “users” as the description for the key, and click Continue.

7. On the Configuration page, select JSON_SR for the output record value format, Users for the template, and click Continue.

8. For Connector sizing, leave the slider at the default of 1 task and click Continue

9. On the Review and launch page, select the text in the Connector name box and replace it with “DatagenSourceConnector_users”.

10. Click Continue to start the connector.

    The status of your new connector should read Provisioning, which lasts for a few seconds. When the status changes to Running, your connector is producing data to the users topic.

    

Step 4: View messages

Your new users topic is now receiving messages. Use Confluent Cloud Console to see the data.

1. From the navigation menu, select Topics to show the list of topics in your cluster.

   

2. Select the users topic.

3. In the users topic detail page, select the Messages tab to view the messages being produced to the topic.

   

Step 5: Inspect the data stream

Use Stream Lineage to track data movement through your cluster.

1. Click Stream Lineage in the navigation menu.

2. Click the node labeled DatagenSourceConnector_users, which is the connector that you created in Step 3. The details view opens, showing graphs for total production and other data.

   

3. Dismiss the details view and select the topic labeled users. The details view opens, showing graphs for total throughput and other data.

   

4. Click the arrow on the left border of the canvas to open the navigation menu.

Step 6: Delete resources (optional)

Skip this step if you plan to move on to Section 2: Query streaming data with Flink SQL and learn how to use Flink SQL statements to query your data.

If you don’t plan to complete Section 2 and you’re ready to quit the Quick Start, delete the resources you created to avoid unexpected charges to your account.

Cloud ConsoleConfluent CLIConfluent Cloud APIs

• Delete the connector:
  1. From the navigation menu, select Connectors.
  2. Click DatagenSourceConnector_users and choose the Settings tab.
  3. Click Delete connector, enter the connector name (DatagenSourceConnector_users), and click Confirm.
• Delete the topic:
  1. From the navigation menu, click Topics, select the users topic, and then choose the Configuration tab.
  2. Click Delete topic, enter the topic name (users), and select Continue.
• Delete the cluster:
  1. From the navigation menu, select Cluster Settings.
  2. Click Delete cluster, enter the cluster name, and click Continue.

Section 2: Query streaming data with Flink SQL

In Section 1, you installed a Datagen connector to produce data to the users topic in your Confluent Cloud cluster.

In this section, you create a Flink workspace and write queries against the users topic and other streaming data.

Step 1: Create a Flink workspace

To write queries against streaming data in tables, create a new Flink workspace.

1. Navigate to the Environments page, and in the navigation menu, click Stream processing.

2. In the dropdown, select the environment where you created the users topic and the Datagen Source connector.

3. Click Create workspace.

   Tip

   To experiment with example data streams provided by Confluent Cloud for Apache Flink, click Try example to open a curated Flink workspace that has example Flink SQL queries you can run immediately.

   A new workspace opens with an example query in the code editor, or cell.

   

   Under the hood, Confluent Cloud for Apache Flink is creating a compute pool, which represents the compute resources that are used to run your SQL statements.

   It may take a minute or two for the compute pool to be provisioned. The status is displayed in the upper-right section of the workspace.

Step 2: Run Flink SQL statements

When the compute pool status changes from Provisioning to Running, it’s ready to run queries.

1. Click Run to submit the example query.

   The example statement is submitted, and information about the statement is displayed, including its status and a unique identifier. Click the Statement name link to open the statement details view, which displays the statement status and other information. Click X to dismiss the details view.

   After an initialization period, the query results display beneath the cell.

   Your output should resemble:

   EXPR$0
   0
   1
   2
   

2. Clear the previous query from the cell and run the following query to inspect the users stream.

   Confluent Cloud for Apache Flink registers tables automatically on your Kafka topics, and your query runs against the users table with the streaming data from the underlying topic.

   SELECT * FROM users;
   

   Your output should resemble:

   key             registertime  userid regionid gender
   x'557365725f34' 1502088104187 User_4 Region_1 MALE
   x'557365725f32' 1500243991207 User_2 Region_9 FEMALE
   x'557365725f32' 1497969328414 User_2 Region_9 OTHER
   ...
   

3. Click Stop to end the query.

   Data continues to flow from the Datagen connector into the users table even though the SELECT query is stopped.

Step 3: Mask a field

With a Flink compute pool running, you can run sophisticated SQL queries on your streaming data.

In this step, you run a Flink SQL statement to hide personal information in the users stream and publish the scrubbed data to a new Kafka topic, named users_mask.

1. Run the following statement to create a new Flink table based on the users table.

   CREATE TABLE users_mask LIKE users;
   

2. When the status of the previous statement is Completed, run the following statement to inspect the schema of the users_mask table.

   DESCRIBE users_mask;
   

   Your output should resemble:

   +--------------+-----------+----------+------------+
   | Column Name  | Data Type | Nullable |   Extras   |
   +--------------+-----------+----------+------------+
   | key          | BYTES     | NULL     | BUCKET KEY |
   | registertime | BIGINT    | NULL     |            |
   | userid       | STRING    | NULL     |            |
   | regionid     | STRING    | NULL     |            |
   | gender       | STRING    | NULL     |            |
   +--------------+-----------+----------+------------+
   

3. Run the following statement to start a persistent query that uses the Flink REGEXP_REPLACE function to mask the value of the gender field and stream the results to the users_mask table.

   INSERT INTO users_mask SELECT
     `key`,
     registertime,
     userid,
     regionid,
     REGEXP_REPLACE(gender, '(\w)', '*') as gender
   FROM users;
   

   The INSERT INTO FROM SELECT statement runs continuously until you stop it manually.

1. Click to create a new cell, and run the following statement to inspect the rows in the users_mask table.

   SELECT * FROM users_mask;
   

   Your output should resemble:

   key             registertime  userid regionid gender
   x'557365725f34' 1488737391835 User_4 Region_5 *****
   x'557365725f34' 1499070045309 User_4 Region_5 *****
   x'557365725f32' 1505447077187 User_2 Region_7 *****
   x'557365725f34' 1505592707164 User_4 Region_2 *****
   ...
   

2. Click Stop to end the SELECT statement.

   The INSERT INTO statement that you started previously continues streaming data into the users_mask topic.

Step 4: View the Stream Lineage

Your Flink SQL statements are resources in Confluent Cloud, like topics and connectors, so you can view them in Stream Lineage.

1. In the navigation menu, find your environment and click to open it.

   The Kafka clusters in the environment are shown.

2. Click the cluster that has the users_mask topic.

   The Kafka topics in the cluster are shown.

3. Hover over the users_mask topic and click View topic details.

   

4. In the topic details pane, scroll to the Stream Lineage section and click View full lineage.

   

5. Hover over the nodes in the Stream Lineage diagram to see details of the data flow.

Step 5: Delete resources

When you are finished with the Quick Start, delete the resources you created to avoid unexpected charges to your account.

Cloud ConsoleConfluent CLIConfluent Cloud APIs

• Delete the persistent query
  1. Navigate to your environment’s details page and click Flink.
  2. In the statements list, find the statement that has a status of Running.
  3. In the Actions column, click … and select Delete statement.
  4. In the Confirm statement deletion dialog, copy and paste the statement name and click Confirm.
• Delete the connector:
  1. From the navigation menu, select Connectors.
  2. Click DatagenSourceConnector_users and choose the Settings tab.
  3. Click Delete connector, enter the connector name (DatagenSourceConnector_users), and click Confirm.
• Delete the topics:
  1. From the navigation menu, click Topics, select the users topic, and choose the Configuration tab.
  2. Click Delete topic, enter the topic name (users), and click Continue.
  3. Repeat these steps with the users_mask topic.

Related content

• Stream Processing with Confluent Cloud for Apache Flink
• Learn about Connectors: Connect External Systems to Confluent Cloud
• Learn about schema management in Confluent Cloud: Quick Start for Schema Management on Confluent Cloud
• Learn how to Connect Clients to Confluent Cloud
• Configure Multi-Node Environment
• Try out the Confluent Cloud Demos and Examples
• Learn about serverless infrastructure: Cloud-Native Apache Kafka: Designing Cloud Systems for Speed and Scale