Advertise
MCP.so
Sign In

MSK MCP Server

@yhyyz

Repository

Basic information

Category

Other

License

MIT

Transports

stdio

Author

yhyyz

About MSK MCP Server

MSK and MirrorMaker2 on MSK connector managed through MCP server

#msk#mcp#server#kafka#amazon

MSK MCP Server config

Add this server to your MCP-compatible client using the configuration below.

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

MSK MCP Server tools

Tool list not available yet

This listing does not currently have a tool list to display. This does not mean the server has no tools; check its documentation for supported capabilities.

We auto-extract tools from the README. The maintainer can list them under a ## Tools heading to populate this section.

Overview

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.

Frequently asked questions

1

What AWS permissions are required?

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

2

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.

3

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.

4

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

5

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.

Comments

More Other MCP servers

Awesome Mlops

visenger

A curated list of references for MLOps

14.0K

Senso MCP for Joomla

sensomedia

Senso MCP turns a Joomla 5 or 6 site into a remote MCP server. It runs inside Joomla itself (no extra server, no Node.js bridge) and is secured with OAuth 2.1 and Joomla's own ACL. The free pack lets an AI assistant crea

EverArt

modelcontextprotocol

Model Context Protocol Servers

88.1K

Soar Flight Booking MCP

Soar Flight Booking MCP is a remote MCP server available at https://mcp.soar.flights.

Maestro

mobile-dev-inc

Painless E2E Automation for Mobile and Web

14.8K
Advertise