Skip to main content
Glama

Kafka MCP Server

A Model Context Protocol server implementation for Apache Kafka. Enabling MCP client to interact with topics hosted in a Kafka instance.

Running locally with the Claude desktop app

Manual Installation

  1. Clone this repository.

  2. Add the following to your claude_desktop_config.json file:

  • On MacOS: ~/Library/Application\ Support/Claude/claude_desktop_config.json

  • On Windows: %APPDATA%/Claude/claude_desktop_config.json

{
    "mcpServers": {
      "kafka": {
        "command": "uv",
        "args": [
            "--directory",
            "/path/to/repo/mcp-kafka",
            "run",
            "mcp-server-kafka",
            "--kafka-bootstrap-servers",
            "<comma_separated_bootstrap_servers ex. localhost:9092,otherhost:9092>",
            # Add other Kafka connection arguments as needed (e.g., security protocol, SASL mechanism, username, password)
            # Example for SASL_SSL:
            # "--kafka-security-protocol", "SASL_SSL",
            # "--kafka-sasl-mechanism", "PLAIN",
            # "--kafka-sasl-plain-username", "<your_username>",
            # "--kafka-sasl-plain-password", "<your_password>"
        ]
      }
    }
}
  1. Install and open the Claude desktop app.

  2. Try asking Claude to do a read/write operation of some sort to confirm the setup (e.g. ask it to publish a message to a topic or read messages from a topic). If there are issues, use the Debugging tools provided in the MCP documentation here.

Related MCP Connectors

Related MCP Servers

  • A
    license
    Not graded
    quality
    D
    maintenance
    Enables AI models to publish and consume messages from Apache Kafka topics through a standardized interface, making it easy to integrate Kafka messaging with LLM and agent applications.
    17
    Apache 2.0
  • F
    license
    Not graded
    quality
    D
    maintenance
    Enables AI assistants to manage and monitor Apache Kafka clusters through natural language, providing real-time operations, health monitoring, consumer lag analysis, and temporal trend detection for intelligent cluster management.
    -
  • A
    license
    Not graded
    quality
    B
    maintenance
    Enables AI agents to interact with Apache Kafka through natural language, supporting operations like producing/consuming messages, managing topics, and querying brokers, partitions, and consumer group offsets.
    1
    MIT
  • A
    license
    Not graded
    quality
    D
    maintenance
    Enables interaction with Kafka clusters via MCP, supporting topic management (list, create, delete, inspect), connection initialization, and more through natural language.
    1
    Apache 2.0