Kafka MCP

The Kafka MCP Server offers efficient way to convert prompts into actions into Kafka ecosystem. It is a natural language interface designed for agentic applications to efficiently manage Kafka operations and integrate seamlessly with MCP Clients enabling AI driven workflows to interact with processes in Kafka. Using this MCP Server, you can ask questions like:
- Publish message 'i am using kafka server' on the topic 'test-kafka'
- Consume the message from topic 'test-kafka'
- List all topics from the kafka environment

- Natural Language Queries: Enables AI agents to query and update Redis using natural language.
- Seamless MCP Integration: Works with any MCP client for smooth communication.
- Full Kafka Support: Handles producer, consumer, topics, broker, partitions and offsets.
- Scalable & Lightweight: Designed for high-performance data operations.

This MCP Server offers various tools for Kafka:

consumerandproducertools allow to consumer and publish message on topics

topictools allow tolist,create,deleteanddescribetopics in Kafka.

partitiontools allow to get partitions and partition offsets.

group_offsettools allow to get and reset offsets in Kafka.

set the following in.envfile or export manually

BOOTSTRAP_SERVERS=your_kafka_server MCP_TRANSPORT=stdio

# Using venv (built-in) python3 -m venv .venv # Activate the virtual environment # On Windows .venv\Scripts\activate # On macOS/Linux source .venv/bin/activate

# Using pip pip install -r requirements.txt # Or using uv (faster) uv pip install -r requirements.txt

BOOTSTRAP_SERVERS=<your_kafka_url> MCP_TRANSPORT=stdio

python3 src/main.py # OR uv run python3 src/main.py

Add the following configuration to your MCPO server's config.json file (e.g., in Claude Desktop):

{ "mcpServers": { "kafka-mcp": { "command": "python3", "args": ["/Users/I528600/Desktop/mcp/kafka-mcp/src/main.py"], "env": { "BOOTSTRAP_SERVERS": "localhost:9092", "MCP_TRANSPORT": "stdio" } } } }

- List all topics in the kafka cluster
- Create topic 'my-kafka' in kafka cluster
- Publish a message 'hello from mcp' to the topic 'my-kafka' in cluster
- Consume 2 messages from the topic 'my-kafka' in kafka cluster
- Describe the topic 'my-kafka'

This is a web browser that enables your coding agent, such as Claude Code, to visit websites on your behalf and assist you in identifying bugs or creating UI test cases.

Integrate with the Coolify API to manage your servers, applications, and databases.

Comprehensive MCP server for managing self-hosted Supabase on Coolify with full deployment, migrations, edge functions, and rollback support.

The official developer experience MCP Server for Amazon DynamoDB. This server provides DynamoDB expert design guidance and data modeling assistance.

All Azure MCP tools in a single server. The Azure MCP Server implements the MCP specification to create a seamless connection between AI agents and Azure services. Azure MCP Server can be used alone or with the GitHub Copilot for Azure extension in VS Code.

Access and interact with Harness platform data, including pipelines, repositories, logs, and artifact registries.

An SSE-based MCP server that allows LLM-powered applications to interact with OCI registries. It provides tools for retrieving information about container images, listing tags, and more.

The Railway MCP Server enables natural language interaction with your Railway projects and infrastructure. Ask your IDE or AI assistant to create projects, deploy templates, manage environments, pull variables, redeploy services, and more.

The Shipyard CLI provides an MCP server for agents to manage Shipyard environments directly: by pulling logs, comparing branches, running tests, and stopping/starting environments..

Secure virtual machines for agents hosted by Superserve

An MCP server for interacting with SAP systems using ABAP Development Tools (ADT).