# Getting Started with Confluent Cloud (Self-Managed)

This guide shows how to use the SingleStore Kafka Sink connector ("the connector") on Confluent Cloud by deploying it on a self-managed Kafka Connect cluster and connecting to your SingleStore deployments.

SingleStore recommends having hands-on experience with Confluent Cloud and an understanding of its concepts. Refer to [Connect Self-Managed Kafka Connect to Confluent Cloud](https://docs.confluent.io/cloud/current/cp-component/connect-cloud-config.html) for related information.

## Prerequisites

* An active SingleStore deployment.
* Access to a [Confluent Cloud](https://www.confluent.io/confluent-cloud/) cluster.

## Configure the Connection

To connect to your SingleStore deployment from Confluent Cloud using the SingleStore Kafka Sink connector, perform the following tasks:

1. [Download](https://docs.confluent.io/platform/current/installation/installing_cp/zip-tar.html#get-the-software) the latest ZIP or TAR distribution of Confluent Platform and extract it.

2. Launch a Confluent Cloud cluster. Refer to [Quick Start for Confluent Cloud](https://docs.confluent.io/cloud/current/get-started/index.html#cloud-quickstart) for more information.

3. Create a topic.

   1. On the Confluent dashboard, select **Topics > Add topic**.

   2. On the **New topic** page, enter a name for the topic and the number of partitions.

   3. Select **Create with defaults > Skip**.

   4. Add data to the Kafka topic.

      1. Select **Topics > \<your\_Kafka\_Topic> > Messages > Produce new message**. This example uses a Kafka topic named **SingleStore-quickstart**.

      2. On the **Produce a new message** dialog, add a message. In this example the following are added:
         | **Key**   | `1`                                                                                                                                                                                                                                                                                                                                            |
         | --------- | ---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- |
         | **Value** | `{"schema": {"type": "struct", "optional": false, "version": 1, "fields": [{ "field": "Id", "type": "string", "optional": true }, { "field": "Artist", "type": "string", "optional": true }, { "field": "Song", "type": "string", "optional": true }] }, "payload": { "Id": "1", "Artist": "Rick Astley", "Song": "Never Gonna Give You Up"}}` |

      3. Select **Produce**.

4. Generate a Kafka Connect properties file.

   1. On the Confluent Platform, select **Connectors**.

   2. Search and select the **SingleStore Sink Connector** from the list of connectors.

   3. On the **Configure SingleStore Sink Connector** page, select **Next**.

   4. Under **Connect to Confluent Cloud**, select **Standalone**.

   5. Select **Create Kafka cluster API key & secret**.

   6. Select **Create Schema Registry API key & secret**.

   7. Select **Generate Config**.

   8. Copy the generated file.

5. In your local environment, create the `/<path_to_confluent>/confluent-<version>/etc/my-connect-standalone.properties` file and paste the configuration in this file.

6. Download the `singlestore-singlestore-kafka-connector-<version>.zip` file from the [SingleStore Kafka Connector](https://github.com/memsql/singlestore-kafka-connector/releases/latest/) GitHub repository.

7. Extract the downloaded `.zip` archive to `/<path_to_confluent>/confluent-<version>/plugins/` directory.

8. Append `plugin.path=/path/to/confluent-<version>/plugins/` to the `my-connect-standalone.properties` file.

9. Create a connection configuration file `/<path_to_confluent>/confluent-<version>/etc/singlestore-sink.properties`, and add the following to the file:
   ```
   name=singlestore-sink-connector
   connector.class=com.singlestore.kafka.SingleStoreSinkConnector
   topics=SingleStore-quickstart
   connection.ddlEndpoint=<hostname_or_IP_address_of_SingleStore_deployment>
   connection.database=<SingleStore_Database>
   connection.user=<SingleStore_User>
   connection.password=<Password>
   value.converter=org.apache.kafka.connect.json.JsonConverter
   value.converter.schemas.enable=true
   ```
   where,
   | **Key**                                          | **Value**                                                              |
   | ------------------------------------------------ | ---------------------------------------------------------------------- |
   | `connection.ddlEndpoint``connection.dmlEndpoint` | IP address or hostname of theSingleStoredeployment.                    |
   | `connection.database`                            | Name of theSingleStoredatabase to connect with.                        |
   | `connection.user`                                | Name of theSingleStoredatabase user with which to access the database. |
   | `connection.password`                            | Password for theSingleStoredatabase user.                              |
   | `topics`                                         | List of Kafka topics.                                                  |
   | `value.converter`                                | Set to`org.apache.kafka.connect.json.JsonConverter`.                   |
   | `value.converter.schemas.enable`                 | Set to`true`.                                                          |
   Refer to [SingleStore Kafka Sink Connector Properties](https://docs.singlestore.com/db/v9.1/load-data/integrate-with-singlestore/singlestore-kafka-sink-connector/singlestore-kafka-sink-connector-properties.md) for more information.

10. Start Kafka Connect. Run the following command in the Confluent directory:
    ```shell
    ./bin/connect-standalone  ./etc/my-connect-standalone.properties ./etc/singlestore-sink.properties
    ```

11. Wait a few minutes, and then log in to your SingleStore deployment and run the following command to verify that the data has been ingested.
    ```sql
    SELECT * FROM `SingleStore-quickstart`;

    ```
    ```output

    +------+-------------+-------------------------+
    | Id   | Artist      | Song                    |
    +------+-------------+-------------------------+
    | 1    | Rick Astley | Never Gonna Give You Up |
    +------+-------------+-------------------------+
    ```

***

Modified at: August 3, 2025

Source: [/db/v9.1/load-data/integrate-with-singlestore/singlestore-kafka-sink-connector/getting-started-with-confluent-cloud-self-managed/](https://docs.singlestore.com/db/v9.1/load-data/integrate-with-singlestore/singlestore-kafka-sink-connector/getting-started-with-confluent-cloud-self-managed/)

(An index of the documentation is available at /llms.txt)