Managed Streaming for Kafka MCP Server
Managed Streaming for Kafka API provides programmatic control over Amazon Managed Streaming for Apache Kafka (Amazon MSK), a fully managed service that enables building and running applications that use Apache Kafka to process streaming data.
Quick Start Summary
The Managed Streaming for Kafka MCP server is a Model Context Protocol bridge that connects AI assistants — including Claude Desktop, Cursor, Windsurf, and VS Code Copilot — to the Managed Streaming for Kafka API through natural language. It exposes 10 API endpoints as callable tools, such as ListScramSecrets, BatchAssociateScramSecret, BatchDisassociateScramSecret, and more. No authentication is required — setup takes approximately 30 seconds. The server uses STDIO transport and can be installed by running npx -y @mcp/amazonaws-com-kafka. This integration is sourced from the auto Managed Streaming for Kafka OpenAPI specification (v2018-11-14) and has a quality score of 46/99 (fair documentation coverage).
Server Details
- Category
- Developer Tools
- Authentication
- None
- Endpoints
- 10 operations
- Transport
- STDIO
- Spec Version
- v2018-11-14
- Install Command
npx -y @mcp/amazonaws-com-kafka
Environment Variables
MANAGED_STREAMING_FOR_KAFKA_API_KEYExample: your_managed_streaming_for_kafka_api_key
Top Endpoints
/v1/clusters/{clusterArn}/scram-secretsListScramSecrets
/v1/clusters/{clusterArn}/scram-secretsBatchAssociateScramSecret
/v1/clusters/{clusterArn}/scram-secretsBatchDisassociateScramSecret
/v1/clustersListClusters
/v1/clustersCreateCluster
One-Click Install
Copy the snippet for your MCP client and paste it in — zero editing required.
Claude Desktop
Add to claude_desktop_config.json
{
"mcpServers": {
"amazonaws-com-kafka": {
"command": "npx",
"args": [
"-y",
"@mcp/amazonaws-com-kafka"
],
"env": {
"MANAGED_STREAMING_FOR_KAFKA_API_KEY": "your_managed_streaming_for_kafka_api_key"
}
}
}
}Cursor
Settings → MCP Servers → Add
{
"mcpServers": {
"amazonaws-com-kafka": {
"url": "https://mcpbridge.org/config/amazonaws-com-kafka.json"
}
}
}Saves as .cursor/mcp.json in the download. Move it to your project root.
VS Code
Use with MCP extension
{
"mcpServers": {
"amazonaws-com-kafka": {
"url": "https://mcpbridge.org/config/amazonaws-com-kafka.json"
}
}
}Endpoints Explorer
Search and browse the 10 operations supported by this server.
Multi-Language Code Examples
Executable code snippets for calling Managed Streaming for Kafka endpoints in curl, TypeScript, or Python.
curl -X GET "https://api.apis.guru/v2/specs/amazonaws.com/kafka/2018-11-14/v1/clusters/{clusterArn}/scram-secrets" \
-H "Content-Type: application/json" \
# No auth requiredManual Configuration
Directly add this block to your JSON config file, or use the hosted config registry URL.
{
"mcpServers": {
"amazonaws-com-kafka": {
"command": "npx",
"args": ["-y","@mcp/amazonaws-com-kafka"],
"env": {
"MANAGED_STREAMING_FOR_KAFKA_API_KEY": "your_managed_streaming_for_kafka_api_key"
}
}
}
}Authentication Details
No authentication required. This MCP server runs out-of-the-box.
Documentation Links
Error Handling & HTTP Status Code Matrix
Common status codes, error causes, and resolution steps when invoking Managed Streaming for Kafka endpoints.
400 Bad RequestCause: Malformed payload parameters or missing required fields.
Resolution: Verify request schema in Endpoints tab before calling tool.
401 UnauthorizedCause: Missing or invalid API key credentials.
Resolution: Set environment variable in MCP client config under env object.
403 ForbiddenCause: Insufficient scope permissions for requested resource.
Resolution: Verify key permissions in developer dashboard.
404 Not FoundCause: Resource URL path or requested entity ID does not exist.
Resolution: Check path variables and parameters.
429 Rate Limit ExceededCause: API rate limit quota exceeded.
Resolution: Implement exponential backoff retry in tool call.
500 Internal ErrorCause: Upstream server runtime fault.
Resolution: Inspect STDIO stderr output for log trace.
Quality Score
Checked against our protocol-compliance rules.
Specification Version: v2018-11-14
Page compiled on: June 13, 2026
Own this API?
Verify ownership of this listing to control the description, configuration details, and documentation links. Choose between free manual verification or instant premium placement.
Option 1: Free Verification
Slow manual review. Requires creating a GitHub issue with verified documentation or domain verification.
- • Verified badge on page
- • Standard search sorting
- • 2-3 business days review
Option 2: Featured Upgrade($9/mo)
Instant verification plus premium styling, featured badges, and directory placement boost.
- • ★ Featured star & amber highlight border
- • Top of directory search placement
- • Instant activation via claim token
📖 Detailed MCP Integration Guide
A technical breakdown of capabilities, agent workflows, and security/configuration best practices.
kafka:DescribeCluster but not kafka:DeleteCluster for a read-only monitoring use case). Credentials should never be hardcoded; instead, use environment variables, AWS SDK defaults, or temporary security credentials from an assumed role. When deploying the MCP server itself, ensure it runs in a secure, isolated environment, as it will act as a proxy for these privileged API actions. All network traffic should be encrypted, and audit logging via AWS CloudTrail should be enabled to track every API call made, providing a complete audit trail for governance and security analysis.Similar APIs
Other APIs in the Developer Tools category.
GitHub API
Access GitHub repositories, issues, pull requests, and more. Integrate GitHub workflows directly into your AI agent.
OAuth2GitLab API
Manage repositories, CI/CD pipelines, and merge requests through your AI agent.
OAuth2Box Platform API
The Box Platform API, provided by Box (box.com), is a robust and comprehensive RESTful service that enables deep integration with the Box cloud content management ecosystem. It serves as the programmatic backbone for enterprises and developers seeking to build custom applications and workflows that interact with content stored securely in Box. Its core capabilities extend far beyond basic file operations, encompassing a full spectrum of content lifecycle management. Developers can programmatically create, upload, download, search, and manage files and folders, but the API's true power lies in its enterprise-grade features. These include advanced collaboration management through invitations and permissions, granular user and group administration within an enterprise directory, and sophisticated security and compliance controls. Specific endpoint groups for managing collaboration whitelists and exempt targets allow for precise governance over external sharing policies, ensuring that content is only shared with approved domains. Furthermore, the API facilitates complex legal and compliance use cases, such as placing items on legal hold or applying retention policies, making it an indispensable tool for regulated industries and large organizations.
Asana
This API serves as the programmatic backbone for the Asana work management platform, provided by Asana, Inc. It enables developers to interact programmatically with one of the world's leading enterprise collaboration and productivity suites. The core capabilities of this interface center around the CRUD (Create, Read, Update, Delete) operations for fundamental Asana objects. Specifically, the provided endpoints grant control over project attachments—allowing for the uploading, retrieval, and management of files associated with tasks and projects—and custom fields, which are pivotal for creating structured, data-rich workflows. These custom fields allow organizations to define unique data types (like dropdown menus, text fields, or dates) to standardize information capture across projects, moving beyond basic task lists to true operational tracking. Typical use cases span from enterprise project management offices (PMOs) needing to programmatically generate status reports and audit attachments, to development teams automating the creation of bug-tracking projects with predefined custom fields for severity and status, to operational leaders building dashboards that aggregate and analyze custom field data for resource allocation insights.
Related MCP Server Integrations
GitHub API MCP Setup
Access GitHub repositories, issues, pull requests, and more. Integrate GitHub workflows directly into your AI agent.
GitLab API MCP Setup
Manage repositories, CI/CD pipelines, and merge requests through your AI agent.
Box Platform API MCP Setup
The Box Platform API, provided by Box (box.com), is a robust and comprehensive RESTful service that enables deep integration with the Box cloud content management ecosystem. It serves as the programmatic backbone for enterprises and developers seeking to build custom applications and workflows that interact with content stored securely in Box. Its core capabilities extend far beyond basic file operations, encompassing a full spectrum of content lifecycle management. Developers can programmatically create, upload, download, search, and manage files and folders, but the API's true power lies in its enterprise-grade features. These include advanced collaboration management through invitations and permissions, granular user and group administration within an enterprise directory, and sophisticated security and compliance controls. Specific endpoint groups for managing collaboration whitelists and exempt targets allow for precise governance over external sharing policies, ensuring that content is only shared with approved domains. Furthermore, the API facilitates complex legal and compliance use cases, such as placing items on legal hold or applying retention policies, making it an indispensable tool for regulated industries and large organizations.
Asana MCP Setup
This API serves as the programmatic backbone for the Asana work management platform, provided by Asana, Inc. It enables developers to interact programmatically with one of the world's leading enterprise collaboration and productivity suites. The core capabilities of this interface center around the CRUD (Create, Read, Update, Delete) operations for fundamental Asana objects. Specifically, the provided endpoints grant control over project attachments—allowing for the uploading, retrieval, and management of files associated with tasks and projects—and custom fields, which are pivotal for creating structured, data-rich workflows. These custom fields allow organizations to define unique data types (like dropdown menus, text fields, or dates) to standardize information capture across projects, moving beyond basic task lists to true operational tracking. Typical use cases span from enterprise project management offices (PMOs) needing to programmatically generate status reports and audit attachments, to development teams automating the creation of bug-tracking projects with predefined custom fields for severity and status, to operational leaders building dashboards that aggregate and analyze custom field data for resource allocation insights.
clickup20 MCP Setup
The clickup20 Polls API is a lightweight, focused web service designed to facilitate the creation and management of simple polling mechanisms. Provided by ClickUp, a platform known for its project management and productivity tools, this API serves as a specialized component for gathering quick, quantitative feedback. Its core capabilities are straightforward: it allows consumers to programmatically retrieve a list of existing poll questions and to submit new poll questions for consideration. Typical use cases span both enterprise and consumer domains. In an enterprise setting, a development team might integrate this API to run quick polls during sprint retrospectives, gauge internal sentiment on a new tool, or gather binary feedback on proposed technical designs within a project management workflow. For consumer applications, it could power simple feedback widgets within a mobile app or website, enabling users to vote on feature priorities or content topics. The API’s simplicity, requiring no authentication, makes it highly accessible for rapid prototyping and integration into internal tools where complex credential management is unnecessary.