> ## Documentation Index
> Fetch the complete documentation index at: https://docs.automq.com/llms.txt
> Use this file to discover all available pages before exploring further.

# RisingWave

> Import data from AutoMQ into RisingWave’s SQL-compatible streaming database. Experience cloud-native scalability, complete Kafka compatibility, and cost efficiency.

[RisingWave](https://risingwave.com/) \[1] is a distributed stream database that provides a standard SQL interface compatible with the PostgreSQL ecosystem, allowing integration without the need for code modification. RisingWave treats streams as tables, enabling users to write complex queries on both streaming and historical data. With RisingWave, users can concentrate on query analytical logic without having to learn Java or the underlying API of specific systems.

This article will guide you on how to import data from AutoMQ into the RisingWave database using [RisingWave Cloud](https://cloud.risingwave.com/) \[2].

## Prepare AutoMQ and Test Data

Refer to [Deploy Multi-Nodes Cluster on Linux▸](/automq/deployment/deploy-multi-nodes-cluster-on-linux) for instructions on deploying AutoMQ, ensuring network connectivity between AutoMQ and RisingWave.

Quickly create a topic named `example_topic` in AutoMQ, and write a test JSON data to it by following these steps.

#### **Create Topic**

Use the Apache Kafka command line tool to create the Topic. Ensure you have access to a Kafka environment and the Kafka service is running. Below is an example command to create the Topic:

```bash theme={null}
./kafka-topics.sh --create --topic exampleto_topic --bootstrap-server 10.0.96.4:9092  --partitions 1 --replication-factor 1

```

<Tip>
  When executing the command, replace the `topic` and `bootstrap-server` with the actual Kafka server address.
</Tip>

After creating the Topic, you can use the following command to verify whether the Topic has been successfully created.

```bash theme={null}
./kafka-topics.sh --describe example_topic --bootstrap-server 10.0.96.4:9092
```

#### **Generate Test Data**

Generate test data in JSON format that corresponds to the table mentioned earlier.

```json theme={null}
{
  "id": 1,
  "name": "Test User"
  "timestamp": "2023-11-10T12:00:00",
  "status": "active"
}

```

#### **Write Test Data**

Use Kafka's command line tool or programming methods to write the test data into the Topic named example\_topic. Below is an example using the command line tool:

```bash theme={null}
echo '{"id": 1, "name": "Test User", "timestamp": "2023-11-10T12:00:00", "status": "active"}' | sh kafka-console-producer.sh --broker-list 10.0.96.4:9092 --topic example_topic

```

Use the following command to view the data just written to the topic:

```bash theme={null}
sh kafka-console-consumer.sh --bootstrap-server 10.0.96.4:9092 --topic example_topic --from-beginning
```

<Tip>
  When executing the command, replace the `topic` and `bootstrap-server` with the actual Kafka server address.
</Tip>

## Creating an AutoMQ Source on RisingWave Cloud

1. Go to [RisingWave Cloud](https://cloud.risingwave.com/) \[3] and open **Clusters** to set up a cluster.

2. Open **Source** in RisingWave Cloud \[4] to set up a source.

3. Specify the cluster and database, and log in to the database.

4. AutoMQ is 100% compatible with Apache Kafka®. Click **Create source** and select Kafka.

5. Configure the connector according to the RisingWave Cloud guided interface, setting the source information and schema details.

6. Confirm the generated SQL statement and click **Confirm** to complete the creation of the source.

<Note>
  The default port for AutoMQ is 9092, and SSL is not enabled. If you need SSL, see the [Apache Kafka Documentation](https://kafka.apache.org/documentation/#security_ssl) \[5].

  In this example, you can set the startup mode to earliest and use JSON format to access all data from the topic from the beginning.
</Note>

## Query Data

1. Go to [RisingWave Cloud](https://cloud.risingwave.com/) \[6] and open **Console** to log into your cluster.

2. Run the following SQL statement to access the imported data, replacing the variable your\_source\_name with the custom name specified when creating the source.

```sql theme={null}
SELECT * from {your_source_name} limit 1;

```

## Citation

\[1] RisingWave: [https://risingwave.com/](https://risingwave.com/)

\[2] RisingWave Cloud: [https://cloud.risingwave.com/](https://cloud.risingwave.com/)

\[3] RisingWave Cloud: [https://cloud.risingwave.com/](https://cloud.risingwave.com/)

\[4] RisingWave Cloud Source: [https://cloud.risingwave.com/](https://cloud.risingwave.com/)

\[5] Apache Kafka Documentation: [https://kafka.apache.org/documentation/#security\_ssl](https://kafka.apache.org/documentation/#security_ssl)

\[6] RisingWave Cloud Console: [https://cloud.risingwave.com/](https://cloud.risingwave.com/)