MSK MCP Server

@yhyyz

代码仓库

基本信息

分类

其他

许可证

MIT

传输方式

stdio

作者

yhyyz

关于 MSK MCP Server

MSK and MirrorMaker2 on MSK connector managed through MCP server

#msk#mcp #server #kafka #amazon

MSK MCP Server 配置

使用下面的配置,将此服务器添加到你的 MCP 客户端。

{
  "mcpServers": {
    "msk-mcp-server": {
      "command": "python",
      "args": [
        "-m",
        "mcp_server_msk_mm2"
      ]
    }
  }
}

MSK MCP Server 工具

工具列表暂未提供

当前收录暂时没有可展示的工具列表，不代表服务没有工具。请查阅项目文档了解支持的能力。

工具是从 README 中自动提取的。维护者可以在 ## Tools 标题下列出工具,即可填充这部分内容。

概览

What is MSK MCP Server?

A Model Context Protocol server that provides management capabilities for Amazon MSK (Managed Streaming for Apache Kafka), including MirrorMaker2 connectors, custom domain creation, and disaster recovery operations. It enables LLMs to create, configure, and manage complete MSK infrastructure with DNS management and DR switching.

How to use MSK MCP Server?

Install via pip (pip install msk-mcp-server) or use uvx without installation. Configure it in Claude or VS Code by specifying the command and environment variables for AWS region, profile, or keys. Run as a script using python -m mcp_server_msk_mm2.

Key features of MSK MCP Server

Complete MirrorMaker2 pipeline orchestration with three connector types.
Custom plugin management with automatic S3 integration.
Disaster recovery switching between primary and secondary MSK clusters.
Route53 integration for custom DNS domain creation and VPC association.
Supports IAM, PLAINTEXT, and SCRAM-SHA-512 authentication.
Real-time monitoring and automated waiting for plugin and connector states.

Use cases of MSK MCP Server

Automating failover between MSK clusters across regions for disaster recovery.
Setting up cross-cluster data replication via MirrorMaker2 connectors.
Creating custom DNS domains for MSK clusters with Route53.
Monitoring and troubleshooting MSK Connect connectors and plugins.

常见问题

What AWS permissions are required?

The server needs permissions for kafkaconnect, kafka, s3 (GetObject, PutObject, ListBucket), route53, ec2:DescribeSubnets, and ec2:DescribeVpcs.

Can it run without an existing S3 bucket?

No, an S3 bucket is required to store MirrorMaker2 plugin files, with proper IAM permissions for MSK Connect to access it.

What authentication methods does the server support?

The MirrorMaker2 module supports IAM, PLAINTEXT, and SCRAM-SHA-512 authentication for source and target clusters. The custom domain module only supports PLAINTEXT.

How do I configure environment variables?

Set AWS_REGION (default uses SDK default), AWS_PROFILE, or AWS_ACCESS_KEY_ID/AWS_SECRET_ACCESS_KEY. Optional timeouts: AWS_READ_TIMEOUT (default 300s) and AWS_CONNECT_TIMEOUT (default 60s).

Is a Route53 hosted zone required for all features?

No, Route53 hosted zones are only required when using the custom domain and disaster recovery functionality.

其他分类下的更多 MCP 服务器

ICSS

chokcoco

不止于 CSS

20.7K

Codelf

unbug

A search tool helps dev to solve the naming things problem.

14.2K

Next Generation Movers: free moving quotes (remote MCP)

Next Generation Movers

Free moving quotes for AI agents from Next Generation Movers, a licensed interstate mover (USDOT 3764697). US long-distance nationwide and local DC/MD/VA. Indicative ballpark price and booking options; optional $0.01 x40