Redpanda Cloud Quickstart

The fastest and easiest way to start data streaming is with a Serverless cluster free trial. Redpanda instantly prepares an account for you that includes a welcome cluster with a hello-world demo topic you can explore. You interact with Serverless clusters the same way you’d interact with Dedicated or BYOC clusters. To learn more, see Serverless.

The following steps describe how to spin up a Dedicated cluster with Redpanda Cloud, create a basic streaming application using the rpk command-line tool, and explore your cluster in Redpanda Console.

Prerequisites

Deploy Redpanda

To create a Dedicated Cloud cluster, log in to Redpanda Cloud.

On the Clusters page, click Create cluster, then click Create Dedicated cluster.
For cluster settings, enter redpandaquickstart for the cluster name. Use default values for the remaining properties, and click Next.
On the Networking page, use the default Public connection type, and click Create.

Wait for your network and your cluster to be created.

Start streaming

To start building a basic streaming application, you can use rpk, Redpanda’s CLI, to create a topic, produce messages to it, and consume messages from it.

Install rpk on your local machine:

The rpk binary is not supported on Windows.
- Linux
- macOS
Download the rpk archive for Linux.

To download the latest version of rpk:

curl -LO https://github.com/redpanda-data/redpanda/releases/latest/download/rpk-linux-amd64.zip

To download a version other than the latest:

curl -LO https://github.com/redpanda-data/redpanda/releases/download/v<version>/rpk-linux-amd64.zip

Ensure that you have the folder ~/.local/bin:

mkdir -p ~/.local/bin

Add it to your $PATH:

export PATH="~/.local/bin:$PATH"

Unzip the rpk files to your ~/.local/bin/ directory:

unzip rpk-linux-amd64.zip -d ~/.local/bin/

Run rpk --version to display the version of the rpk binary:

rpk --version

rpk version 24.2.12 (rev 044242a)
If you don’t have Homebrew installed, install it.

Install rpk:

brew install redpanda-data/tap/redpanda

Run rpk --version to display the version of the rpk binary:

rpk --version

rpk version 24.2.12 (rev 044242a)

This method installs the latest version of rpk, which is supported only with the latest version of Redpanda.
On the Overview page of Redpanda Cloud, copy your bootstrap server address and set it as an environment variable on your local machine:
```
export RPK_BROKERS="<bootstrap-server-address>"
```
In Redpanda Cloud, go to Security and create a user called redpanda-chat-account that uses the SCRAM-SHA-256 mechanism.

Copy the password, and set the following environment variables on your local machine:

export REDPANDA_SASL_USERNAME="redpanda-chat-account"
export REDPANDA_SASL_PASSWORD="<password>"
export REDPANDA_SASL_MECHANISM="SCRAM-SHA-256"

In Redpanda Cloud, click the name of your user and add the following permissions to the ACL (access control list):
- Host: *
- Topic name: chat-room
- Operations: All
Click Create.
Use rpk on your local machine to authenticate to Redpanda as the redpanda-chat-account user and get information about the cluster:
```
rpk cluster info -X tls.enabled=true
```
Create a topic called chat-room.

You granted permissions to the redpanda-chat-account user to access only this topic.
```
rpk topic create chat-room -X tls.enabled=true
```
Output:
```
TOPIC       STATUS
chat-room  OK
```

Produce a message to the topic:

rpk topic produce chat-room -X tls.enabled=true

Enter a message, then press Enter:

Pandas are fabulous!

Example output:

Produced to partition 0 at offset 0 with timestamp 1663282629789.

Press Ctrl+C to finish producing messages to the topic.

Consume one message from the topic:

rpk topic consume chat-room --num 1 -X tls.enabled=true

Your message is displayed along with its metadata:

{
  "topic": "chat-room",
  "value": "Pandas are fabulous!",
  "timestamp": 1663282629789,
  "partition": 0,
  "offset": 0
}

Explore your topic

In Redpanda Cloud, go to Topics > chat-room.

The message that you produced to the topic is displayed along with some other details about the topic.

Clean up

If you don’t want to continue experimenting with your cluster, you can delete it.

Go to Cluster settings and click Delete cluster.

Next steps

Learn more about Redpanda Cloud

Suggested reading

Learn more about rpk and explore the rpk commands that you used in this quickstart:

Was this helpful?

group Ask in the community

mail Share your feedback

group_add Make a contribution

${preview ? html`

${ preview.breadcrumbs ? html`

${breadcrumb.t}

` : '' }

${components.Highlight({ hit: preview, attribute: 'title', })}

${components.Highlight({ hit: preview, attribute: 'intro', })}

${ preview.image ? html`

${preview.type == 'Doc' ? html`

` : html`

` }

` : '' }

${preview.titles && preview.titles.length > 0 ? html`

` : '' } `, root ); }, getSources({ query, state }) { const tagsByFacet = groupBy( state.context.tagsPlugin.tags, (tag) => tag.facet ); return [ { sourceId: 'filters', getItems({ query }) { return getAlgoliaFacets({ searchClient, queries: [ { indexName: 'redpanda', facet: '_tags', params: { facetQuery: '', }, }, ], // Removes filters from the list after they've been applied // to prevent confusion where a filter is applied but can still be clicked transformResponse({ facetHits }) { const existingTags = (tagsByFacet["_tags"] || []).map(tag => tag.label); return facetHits[0] .filter(hit => !existingTags.includes(hit.label) ) .map(hit => ({ ...hit, facet: '_tags' })); }, }); }, templates: { item({ item, components, html }) { return html`

${components.Highlight({ hit: item, attribute: 'label' })}

`; }, header({items, html}) { if (!items.length) { return; } let headerTitle = "Add filters"; return html` ${headerTitle}

`; }, }, }, { sourceId: 'docs', getItems() { return getAlgoliaResults({ searchClient, queries: [ { indexName: 'redpanda', query, params: { clickAnalytics: true, hitsPerPage: 10, attributesToSnippet: ['*:25'], snippetEllipsisText: '…', tagFilters: mapToAlgoliaFilters(tagsByFacet), }, }, ], transformResponse({ hits }) { return hits.map(nestedHits => { const docIndices = new Map(); nestedHits.forEach((item, index) => { if (item.type === 'Doc') { docIndices.set(index, item); } }); const nonDocItems = nestedHits.filter(item => item.type !== 'Doc' && typeof item.unixTimestamp === 'number') .sort((a, b) => b.unixTimestamp - a.unixTimestamp); let nonDocIndex = 0; docIndices.forEach((item, index) => { if (item._highlightResult && item._highlightResult.titles) { const matchedIndex = item._highlightResult.titles.findIndex(title => title.t.matchLevel === "full"); if (matchedIndex !== -1) { const matchedTopLevelTitle = item.titles[matchedIndex]; if (matchedTopLevelTitle) { item.matchingHeading = `#${matchedTopLevelTitle.h}`; } } } nestedHits[index] = item; }); return nestedHits.map((item, index) => { return docIndices.has(index) ? docIndices.get(index) : nonDocItems[nonDocIndex++]; }); }); }, }) }, templates: { noResults({state, html}) { state.context.preview = null if (!state.query) return return html`

No results for ${state.query}

Believe this query should return results? Let us know.

`; }, header({items, html}) { if (!items.length) { return; } return html` Results

`; }, footer({state, html}) { if (state.context.preview) { var queryParams = state.query ? `q=${encodeURIComponent(state.query)}` : ''; if (VERSION) { queryParams += `&version=${VERSION}` } return html``; } }, item({ item, components, html }) { const matchingHeading = item.matchingHeading || '' const aTag = item.type == 'Doc' ? html`

${components.Highlight({ hit: item, attribute: 'title', })}

${ item.text ? html`

${components.Snippet({ hit: item, attribute: 'text', })}

` : html`

${components.Snippet({ hit: item, attribute: 'intro', })}

` }

${item.type}

${item.product ? html`

${item.product}

` : '' } ${item.version ? html`

${item.version}

` : '' }

` : html`

${components.Highlight({ hit: item, attribute: 'title', })}

${ item.breadcrumbs ? html`

` : '' }

${components.Snippet({ hit: item, attribute: 'text', })}

${item.type}

${item.version ? html`

${item.version}

` : '' }

` return html`${aTag}`; }, }, getItemUrl({ item }) { return item.objectID; }, onActive({ item, setContext }) { setContext({ preview: item }); }, } ]; }, }); })

Simple online edits

Contribution guide