What do you want to automate
with QuestDB and Confluent?
Prompt, edit and deploy AI agents that connect to QuestDB, Confluent and 3,000+ other apps in seconds.
Trusted by 1,000,000+ developers from startups to Fortune 500 companies
Start for free — no credit card required
Watch a demo
Integrate the QuestDB API with the Confluent API
Setup the QuestDB API trigger to run a workflow which integrates with the Confluent API. Pipedream's integration platform allows you to integrate QuestDB and Confluent remarkably fast. Free for developers.
Connect QuestDB#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
import { Client } from "pg";
export default defineComponent({
props: {
questdb: {
type: "app",
app: "questdb",
}
},
async run({ steps, $ }) {
const client = new Client({
host: this.questdb.$auth.host,
port: this.questdb.$auth.port,
user: this.questdb.$auth.user,
password: this.questdb.$auth.password,
database: this.questdb.$auth.database,
ssl: this.questdb.$auth.ssl
});
await client.connect();
const readAll = await client.query("SELECT version()");
await client.end();
return readAll.rows;
},
})
Overview of Confluent#
The Confluent API provides programmatic interaction with Confluent Cloud, a fully managed Kafka service. It lets you manage Kafka clusters, topics, users, and configurations, enabling seamless integration and data streaming capabilities. With Pipedream, you can create workflows that automate interactions with your Kafka infrastructure, such as triggering events on message arrival, managing topics, or integrating Kafka data with other services.
Connect Confluent#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
import { axios } from "@pipedream/platform"
export default defineComponent({
props: {
confluent: {
type: "app",
app: "confluent",
}
},
async run({steps, $}) {
const data = {
"topic_name": `pipedream-test`,
}
return await axios($, {
method: "post",
url: `https://${this.confluent.$auth.rest_endpoint_url}/kafka/v3/clusters/${this.confluent.$auth.cluster_id}/topics`,
headers: {
"Content-Type": `application/json`,
},
auth: {
username: `${this.confluent.$auth.api_key}`,
password: `${this.confluent.$auth.api_secret}`,
},
data,
})
},
})
Start for free — no credit card required
Watch a demo
Trusted by 1,000,000+ developers from startups to Fortune 500 companies