Produce and consume messages, manage topics, and inspect stats on Upstash serverless Kafka via the REST API.
Use with AI AssistantsMCP
Connect Claude, Cursor, or any MCP-compatible client — then call tools directly
① Add This MCP Server
Paste into your AI client config — then all its tools are available instantly.
{
"mcpServers": {
"upstash-kafka": {
"url": "https://mcp.aerostack.dev/s/aerostack/mcp-upstash-kafka",
"headers": {
"Authorization": "Bearer YOUR_AEROSTACK_TOKEN"
}
}
}
}Replace YOUR_AEROSTACK_TOKEN with your API token from the dashboard.
② Call a Tool
Ask your AI assistant to call a specific tool, or send raw JSON-RPC:
Natural Language Prompt
“Use the _ping tool to verify upstash kafka credentials by listing topics. used internally by aerostack to validate credentials”
Using a Workspace?
Add this MCP to your Workspace — your team shares one token, secrets are stored securely, and every AI agent in the workspace can call it without per-user setup.
Produce and consume messages, manage topics, and inspect stats on Upstash serverless Kafka.
Upstash Kafka is a serverless Kafka service with a REST API — no brokers to manage, pay only for what you use. This MCP server lets your AI agents produce messages to topics, consume from consumer groups, create and delete topics, and check topic statistics, all through the Upstash Kafka REST interface.
Live endpoint: https://mcp.aerostack.dev/s/aerostack/mcp-upstash-kafka
| Tool | Description |
|---|---|
_ping | Verify Upstash Kafka credentials by listing topics (used by Aerostack) |
produce | Send a message to a Kafka topic with optional partition key |
produce_batch | Send multiple messages to one or more topics in a single request |
consume | Read messages from a topic using a consumer group |
list_topics | List all Kafka topics in the cluster |
create_topic | Create a new topic with configurable partitions and retention |
delete_topic | Delete a topic (irreversible) |
get_topic_stats | Get statistics for a topic (partitions, retention, config) |
| Variable | Required | Description | How to Get |
|---|---|---|---|
UPSTASH_KAFKA_REST_URL | Yes | Upstash Kafka REST API URL | console.upstash.com → Kafka → select your cluster → REST API section → copy the UPSTASH_KAFKA_REST_URL |
UPSTASH_KAFKA_REST_USERNAME | Yes | REST API username for authentication | Same page → copy UPSTASH_KAFKA_REST_USERNAME |
UPSTASH_KAFKA_REST_PASSWORD | Yes | REST API password for authentication | Same page → copy UPSTASH_KAFKA_REST_PASSWORD |
UPSTASH_KAFKA_REST_URL, UPSTASH_KAFKA_REST_USERNAME, and UPSTASH_KAFKA_REST_PASSWORD under Project → SecretsOnce added, every AI agent in your workspace can call Kafka tools automatically — no per-user setup needed.
"Send a message to the 'user-signups' topic with the payload { name: 'Alice', plan: 'pro' }"
"Read the latest messages from the 'order-events' topic using consumer group 'analytics'"
"List all Kafka topics in our cluster"
"Create a new topic called 'notifications' with 3 partitions and 30-day retention"
"Get stats for the 'payment-events' topic"
"Delete the 'test-topic' topic"
# Produce a message
curl -X POST https://mcp.aerostack.dev/s/aerostack/mcp-upstash-kafka \
-H 'Content-Type: application/json' \
-H 'X-Mcp-Secret-UPSTASH-KAFKA-REST-URL: https://your-cluster.upstash.io' \
-H 'X-Mcp-Secret-UPSTASH-KAFKA-REST-USERNAME: your-username' \
-H 'X-Mcp-Secret-UPSTASH-KAFKA-REST-PASSWORD: your-password' \
-d '{"jsonrpc":"2.0","id":1,"method":"tools/call","params":{"name":"produce","arguments":{"topic":"user-signups","value":"{\"name\":\"Alice\",\"plan\":\"pro\"}"}}}'
# Consume messages
curl -X POST https://mcp.aerostack.dev/s/aerostack/mcp-upstash-kafka \
-H 'Content-Type: application/json' \
-H 'X-Mcp-Secret-UPSTASH-KAFKA-REST-URL: https://your-cluster.upstash.io' \
-H 'X-Mcp-Secret-UPSTASH-KAFKA-REST-USERNAME: your-username' \
-H 'X-Mcp-Secret-UPSTASH-KAFKA-REST-PASSWORD: your-password' \
-d '{"jsonrpc":"2.0","id":1,"method":"tools/call","params":{"name":"consume","arguments":{"topic":"user-signups","group":"my-consumer-group"}}}'
MIT
Live Endpoint
https://mcp.aerostack.dev/s/aerostack/mcp-upstash-kafka
Sub-50ms globally · Zero cold start
@aerostack
Pre-built functions for the most common MCP tool patterns. Clone, extend, and deploy.
by @aerostack
Discover and invoke any MCP, Function, or Skill published to the Aerostack marketplace — the universal AI capability hub.
by @aerostack
Search indexes, manage records, browse data, and configure ranking in Algolia — AI-native instant search access.
by @aerostack
Query documents, run AQL, traverse graphs, and manage collections in your ArangoDB database — AI-native multi-model database access.
by @aerostack
Post, schedule, and analyze social media across 13 platforms — Facebook, Instagram, X, LinkedIn, TikTok, Bluesky, Threads, Reddit, Pinterest, YouTube, Telegram, Snapchat, Google Business.
by @aerostack
Manage projects, to-dos, messages, schedules, and campfire chats in Basecamp — AI-native project management.
by @aerostack
Run SQL queries, list datasets and tables, inspect schemas, and export results from Google BigQuery — AI-native data warehouse access.
Yes. The Upstash Kafka MCP includes a create_topic tool that lets Claude create topics in your Upstash Kafka account from a plain-English prompt. You can also update and delete topics — no Upstash Kafka UI needed.
Yes. The Upstash Kafka MCP includes tools to list and retrieve topics from your Upstash Kafka account. Claude can filter, sort, and summarize topics based on your instructions.
Yes. The Upstash Kafka MCP uses the open Model Context Protocol standard, so it works in Claude, Cursor, Windsurf, and any other MCP-compatible AI tool. All 7 Upstash Kafka tools are available everywhere you connect it — install once on Aerostack.
Yes. Aerostack hosts the Upstash Kafka MCP with encrypted credential storage and per-account authentication. Your Upstash Kafka credentials are never shared with Claude's conversation — they're used server-side only.