Registry / aws / awslabs-aws-msk-mcp-server

awslabs-aws-msk-mcp-server

library0.0.17pypypiunverified

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.

aws data

pip install awslabs-aws-msk-mcp-server

github ↗package ↗homepage ↗docs ↗changelog ↗

INSTALL

IMPORT

SIG · AWSLABS-AWS-MSK-MC

awslabs-aws-msk-mcp-server

awspythonv0.0.17

Install

—

Import

—

Disk

—

Pass rate

0/ 10

Env Coverage0 / 10

glibc

3.9–3.13

musl

3.9–3.13

Install & Compatibility

Where this runs

tested against v? · pip install

Install × environment matrix

Each cell = how many times install + import succeeded across repeated harness runs. Partial = flaky.
glibc = Debian/Ubuntu slim · musl = Alpine Linux

musl

py 3.10–3.95 runs

build_error

glibc

py 3.10–3.95 runs

build_error

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

MSKMCPServer

✓ from awslabs_aws_msk_mcp_server import server

✗ from awslabs_aws_msk_mcp_server import MSKMCPServer

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'.

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())

Debug

Known issues

breakingVersion 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.

affects: <0.0.17

gotchaThe 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 ...`

affects: all

deprecatedThe `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()`.

affects: >=0.0.15

Upgrade

Version history

0.0.17latest on PyPI · released Mar 6, 2026

Audit

Dependencies

mcprequiredMCP protocol implementation

boto3requiredAWS SDK for Python

Agent activity

37 hits · last 30 days

node

OpenAI (training)

Resources

githubhttps://github.com/awslabs/mcp ↗

packagehttps://pypi.org/project/awslabs-aws-msk-mcp-server/ ↗

homepagehttps://awslabs.github.io/mcp/ ↗

docshttps://awslabs.github.io/mcp/servers/aws-msk-mcp-server/ ↗

changeloghttps://github.com/awslabs/mcp/blob/main/src/aws-msk-mcp-server/CHANGELOG.md ↗