Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Redpanda Connect docs #56

Merged
merged 5 commits into from
Oct 8, 2024
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions sidebars.js
Original file line number Diff line number Diff line change
Expand Up @@ -447,6 +447,7 @@ module.exports = {
"third-party-tools/prometheus",
"third-party-tools/qstudio",
"third-party-tools/redpanda",
"third-party-tools/redpanda-connect",
"third-party-tools/spark",
"third-party-tools/sqlalchemy",
"third-party-tools/superset",
Expand Down
68 changes: 68 additions & 0 deletions third-party-tools/redpanda-connect.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,68 @@
---
title: Redpanda Connect (Benthos)
description: Redpanda Connect, formerly known as Benthos, ships with a QuestDB
output component that can be used as a sink for your stream processing data
---

import Screenshot from "@theme/Screenshot"

## Integration guide

This guide shows the steps to use the QuestDB Kafka connector to read JSON data
from Kafka topics and write them as rows into a QuestDB table. For Confluent
users, please check the instructions in the
[Confluent Docker images](https://github.com/questdb/kafka-questdb-connector/tree/main/kafka-questdb-connector-samples/confluent-docker-images).

### Prerequisites

You will need the following:

- [Redpanda Connect](https://docs.redpanda.com/redpanda-connect/about/)
- A running QuestDB instance

### Download Redpanda Connect

The QuestDB output component was added to Redpanda Connect in version X.X.X

To download the latest version of Redpanda Connect, follow the [installation instructions](https://docs.redpanda.com/redpanda-connect/guides/getting_started/#install) in the official documentation.

### Configure Redpanda Connect

One of Redpanda Connect's strengths is the ability to configure an entire data pipeline in a single
yaml file. We will create a simple configuration to demonstrate the QuestDB connector's capabilities
by using a straightforward input source.

Create this file and name it `config.yaml` in your current directory

```yaml
input:
stdin: {}

output:
questdb:
address: localhost:9000
table: redpanda_connect_demo
doubles:
- price
designated_timestamp_field: timestamp
```

This configuration will read lines from stdin and publish them to your running QuestDB instance

### Run Redpanda Connect and publish messages

Run the following command to send some messages over Influx Line Protocol to QuestDB through Redpanda Connect

```bash
echo '{"symbol": "AAPL", "price": 225.83, "timestamp": 1727294094}
{"symbol": "MSFT", "price": 431.78, "timestamp": 1727294142}` | rpk connect run config.yaml
```

### Verify the integration

Navigate to the QuestDB Web Console at http://localhost:9000 and run the following query to see your data:

```sql
SELECT *
FROM redpanda_connect_demo
```
Loading