ServerlessData Platform

import { Redis } from '@upstash/redis'

const redis = new Redis({
  url: 'https://obi-wan-kenobi-31346.upstash.io',
  token: 'TOKEN',
})
   
const data = await redis.set('foo', 'bar');

// Producer
import { Kafka } from "@upstash/kafka"

const kafka = new Kafka({
  url: "https://dart-vader-9500-eu1-rest-kafka.upstash.io",
  username: "USERNAME",
  password: "PASSWORD",
})

const p = kafka.producer()
const res = await p.produce("<my.topic>", { hello: "world" } )

// Consumer
import { Kafka } from "@upstash/kafka"

const kafka = new Kafka({
  url: "https://dart-vader-9500-eu1-rest-kafka.upstash.io",
  username: "USERNAME",
  password: "PASSWORD",
})

const c = kafka.consumer()

const messages = await c.consume({
  consumerGroupId: "group_1",
  instanceId: "instance_1",
  topics: ["test.topic"],
  autoOffsetReset: "earliest",
})

fetch("https://qstash.upstash.io/v1/publish/https://example.com", {
  body: "{ 'hello': 'world' }",
  headers: {
    Authorization: "Bearer XXX",
    "Content-Type": "application/json",
    "Upstash-Forward-My-Header": "my-value"
  },
  method: "POST"
})