with Kyvio and Confluent?
The Kyvio API allows for automation and integration of Kyvio's suite of tools for building online businesses, including smart memberships, funnels, and email marketing. By leveraging the Kyvio API on Pipedream, you can create automated workflows to streamline operations such as updating member details, managing subscriptions, tracking email campaigns, and more. Pipedream's serverless platform enables you to connect Kyvio with hundreds of other apps to further enhance your business processes with event-driven actions.
import { axios } from "@pipedream/platform"
export default defineComponent({
props: {
kyvio: {
type: "app",
app: "kyvio",
}
},
async run({steps, $}) {
return await axios($, {
url: `https://${this.kyvio.$auth.subdomain}.kyvio.com/api/v1/subscribers`,
headers: {
Authorization: `Bearer ${this.kyvio.$auth.api_key}`,
},
})
},
})
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.
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,
})
},
})