Kafka MCP Server

What it does

Connects AI models to Apache Kafka clusters, allowing them to interact with streaming data, manage topics, and monitor cluster health using the Model Context Protocol.

Tools

• produce_message: Sends messages to specific Kafka topics.
• consume_messages: Batch consumes messages from Kafka topics.
• list_brokers: Retrieves all configured Kafka broker addresses.
• describe_topic: Provides comprehensive metadata for a specific topic.
• list_consumer_groups: Enumerates all consumer groups in the cluster.
• describe_consumer_group: Detailed consumer group info including lag metrics.
• describe_configs: Retrieves configuration settings for Kafka resources.
• cluster_overview: Comprehensive cluster health summaries.
• list_topics: Lists all topics with partition and replication info.

Installation

Add the following to your claude_desktop_config.json:

{
  "mcpServers": {
    "kafka": {
      "command": "kafka-mcp-server",
      "args": [],
      "env": {
        "KAFKA_BROKERS": "localhost:9092",
        "KAFKA_CLIENT_ID": "kafka-mcp-server",
        "MCP_TRANSPORT": "stdio"
      }
    }
  }
}

Supported hosts

• Claude Desktop
• Cursor
• Windsurf