AWS Labs MSK MCP Server

0.0.17 verified Fri May 01 auth: no python

An AWS Labs Model Context Protocol (MCP) server for Amazon MSK (Managed Streaming for Apache Kafka). Provides tools for interacting with MSK clusters, topics, and consumer groups via the MCP interface. Current version: 0.0.17. Release cadence: early stage, irregular.

pip install awslabs-aws-msk-mcp-server

Common errors

error ModuleNotFoundError: No module named 'awslabs-aws-msk-mcp-server' ↓

cause Using hyphens in import statement instead of underscores.

fix

Use underscores: import awslabs_aws_msk_mcp_server

error AttributeError: module 'awslabs_aws_msk_mcp_server' has no attribute 'MSKMCPServer' ↓

cause Trying to import a class that no longer exists (renamed/removed in recent version).

fix

Import the module-level server object instead: from awslabs_aws_msk_mcp_server import server

Warnings

breaking Version 0.0.17 renames the main entry point from `run` to `server.run`. Scripts using `app.run()` will break. ↓

fix Change `app.run()` to `server.run()` and import `server` from the package.

gotcha The package name uses hyphens (awslabs-aws-msk-mcp-server), but imports use underscores (awslabs_aws_msk_mcp_server). Common mistake: using hyphens in import statements. ↓

fix Use underscores when importing: `from awslabs_aws_msk_mcp_server import ...`

deprecated The `MSKMCPServer` class is deprecated in favor of module-level `server` object. Direct instantiation may be removed in future versions. ↓

fix Use `from awslabs_aws_msk_mcp_server import server` and call `server.run()`.

Imports

MSKMCPServer
wrong
```
from awslabs_aws_msk_mcp_server import MSKMCPServer
```
correct
```
from awslabs_aws_msk_mcp_server import server
```
The main server class is named 'server' and is exposed as a module-level instance.

app

from awslabs_aws_msk_mcp_server import app

The ASGI app for MCP is exported as 'app'.

Quickstart

Basic server startup. Requires AWS credentials and MSK cluster ARN via environment variables.

from awslabs_aws_msk_mcp_server import server, app
import asyncio

async def main():
    # Configure with environment variables:
    # AWS_ACCESS_KEY_ID, AWS_SECRET_ACCESS_KEY, AWS_REGION, MSK_CLUSTER_ARN
    # Run the server
    await server.run()

if __name__ == "__main__":
    asyncio.run(main())