MCP.so
Sign In

Credits

@CefBoud

About Credits

No overview available yet

Basic information

Category

Other

Runtime

go

Transports

stdio

Publisher

CefBoud

Config

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

{
  "mcpServers": {
    "kafka": {
      "command": "docker",
      "args": [
        "run",
        "-i",
        "--rm",
        "-e",
        "KAFKA_MCP_BOOTSTRAP_SERVERS",
        "ghcr.io/cefboud/kafka-mcp-server"
      ],
      "env": {
        "KAFKA_MCP_BOOTSTRAP_SERVERS": "localhost:9092"
      }
    }
  }
}

Tools

No tools detected

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

Overview

What is Kafka MCP Server?

The Kafka MCP Server is a Model Context Protocol (MCP) server that provides integration with Apache Kafka, enabling interaction with a Kafka cluster using natural language via LLMs.

How to use Kafka MCP Server?

Requires Docker or Go to run locally, and access to a Kafka cluster. Configure with the KAFKA_MCP_BOOTSTRAP_SERVERS environment variable or --bootstrap-servers flag. Can be run via Docker image ghcr.io/cefboud/kafka-mcp-server or built from source.

Key features of Kafka MCP Server

  • List and create topics
  • Consume and produce messages
  • Describe cluster (brokers and controller)
  • List consumer groups and their lag
  • Get topic's earliest and latest offsets
  • MultiplexTool for batching sequential tool calls

Use cases of Kafka MCP Server

  • Monitor Kafka topics and consumer groups via natural language
  • Automate topic creation and message production from LLM chat
  • Debug cluster state and broker information interactively
  • Execute multi-step Kafka operations in a single request using MultiplexTool

FAQ from Kafka MCP Server

What are the prerequisites?

Docker or Go, and a running Kafka cluster. The quickstart uses docker run -p 9092:9092 apache/kafka:4.0.0.

How do I connect to my Kafka cluster?

Set the KAFKA_MCP_BOOTSTRAP_SERVERS environment variable or the --bootstrap-servers CLI flag.

Can I restrict the server to read-only?

Yes, use the --read-only flag to limit the server to read-only operations.

What is MultiplexTool?

A tool that batches multiple sequential tool calls into one request, with optional dynamic dependencies resolved via LLM prompts (currently Gemini requires GEMINI_API_KEY).

What authentication is supported?

The README does not mention authentication; it assumes a plain connection (e.g., to localhost:9092).

Comments

More Other MCP servers