📊 概述

Upstash Kafka 是完全托管的 Apache Kafka 服务:

  • 完全兼容:支持所有 Kafka 客户端
  • 无分区限制:自动管理分区
  • REST API:支持 HTTP 访问
  • 价格优势:比 Confluent、AWS MSK 便宜

💰 价格对比

服务定价模式起步价
Upstash按请求付费$0 起
Confluent按分区 + 小时$0.01/小时起
AWS MSK按实例$450+/月

关键差异:Confluent 即使不用也要付费(分区费);Upstash 不用不付费。

🚀 快速开始

创建 Kafka 集群

步骤
1. 进入 Dashboard
2. 点击 "Create Database"
3. 选择 "Kafka"
4. 选择区域
5. 创建 Topic

生产消息

bash
# 使用 REST API
curl -X POST \
  -H "Authorization: Basic YOUR_CREDENTIALS" \
  -H "Content-Type: application/json" \
  -d '{"messages":[{"value":"Hello Kafka"}]}' \
  https://xxx.upstash.io/topics/my-topic/messages

消费消息

bash
curl -X GET \
  -H "Authorization: Basic YOUR_CREDENTIALS" \
  "https://xxx.upstash.io/topics/my-topic/messages?partition=0&offset=0"

📚 常见用例

  • 事件流:用户行为、系统事件
  • CDC:数据库变更捕获
  • 日志聚合:集中式日志处理
  • 微服务通信:异步消息传递

⚠️ vs QStash

功能KafkaQStash
消息推送需自己实现✅ 自动
无限吞吐有限额
调度/延迟
重试需配置 DLQ✅ 自动

建议:高吞吐选 Kafka,简单队列选 QStash。