drio
Open app

Overview

Source

An MCP server for Apache Kafka & its ecosystem.

Catalog onlyCatalog onlySTDIO

Overview

MCP Kafka is a server that enables reliable interaction with Apache Kafka and Kafka Connect clusters using the model context protocol (MCP).

To use MCP Kafka, configure the environment variables with your Kafka brokers and utilize the provided tools to interact with the Kafka cluster.

  • Reliable LLM interaction with Kafka clusters. - Tools for pulling cluster metadata, listing topics, and consumer groups. - Support for Kafka Connect integration.
  1. Managing and monitoring Kafka clusters.
  2. Integrating LLMs with Kafka for data processing.
  3. Facilitating communication between different services using Kafka.

Add to your AI client

Use these steps to connect Overview in Cursor, Claude, VS Code, and other MCP-compatible apps. The same JSON appears in the Use with menu above for one-click copy.

Cursor

Add this to your .cursor/mcp.json file in your project root, then restart Cursor.

.cursor/mcp.json

{
  "mcpServers": {
    "mcp-kafka-brandon-powers": {
      "command": "npx",
      "args": [
        "-y",
        "@modelcontextprotocol/server-mcp-kafka-brandon-powers"
      ]
    }
  }
}

Claude Desktop

Add this server entry to the mcpServers object in your Claude Desktop config, then restart the app.

~/Library/Application Support/Claude/claude_desktop_config.json (macOS) or %APPDATA%\Claude\claude_desktop_config.json (Windows)

{
  "mcpServers": {
    "mcp-kafka-brandon-powers": {
      "command": "npx",
      "args": [
        "-y",
        "@modelcontextprotocol/server-mcp-kafka-brandon-powers"
      ]
    }
  }
}

Claude Code

Add this to your project's .mcp.json file. Claude Code will detect it automatically.

.mcp.json (project root)

{
  "mcpServers": {
    "mcp-kafka-brandon-powers": {
      "command": "npx",
      "args": [
        "-y",
        "@modelcontextprotocol/server-mcp-kafka-brandon-powers"
      ]
    }
  }
}

VS Code (Copilot)

Add this to your .vscode/mcp.json file. Requires the GitHub Copilot extension with MCP support enabled.

.vscode/mcp.json

{
  "servers": {
    "mcp-kafka-brandon-powers": {
      "type": "stdio",
      "command": "npx",
      "args": [
        "-y",
        "@modelcontextprotocol/server-mcp-kafka-brandon-powers"
      ]
    }
  }
}

Windsurf

Add this to your Windsurf MCP config file, then restart Windsurf.

~/.codeium/windsurf/mcp_config.json

{
  "mcpServers": {
    "mcp-kafka-brandon-powers": {
      "command": "npx",
      "args": [
        "-y",
        "@modelcontextprotocol/server-mcp-kafka-brandon-powers"
      ]
    }
  }
}

Cline

Open Cline settings, navigate to MCP Servers, and add this server configuration.

Cline MCP Settings (via UI)

{
  "mcpServers": {
    "mcp-kafka-brandon-powers": {
      "command": "npx",
      "args": [
        "-y",
        "@modelcontextprotocol/server-mcp-kafka-brandon-powers"
      ]
    }
  }
}

FAQ

What is the model context protocol (MCP)?

MCP is a protocol designed for reliable interactions with language models in distributed systems.

Is MCP Kafka stable?

Currently, MCP Kafka is a work in progress, and changes or potential errors are expected.

What programming language is MCP Kafka written in?

MCP Kafka is developed in Python.

Developer tools