Apache Kafka MCP

A Model Context Protocol server for Apache Kafka implemented in Go. Lets AI assistants inspect clusters, list and describe topics and consumer groups, produce test messages, and consume recent records, making it easier to debug and operate event-streaming pipelines from natural language.

{
  "mcpServers": {
    "kafka": {
      "command": "npx",
      "args": [],
      "env": {
        "KAFKA_BROKERS": "<YOUR_KAFKA_BROKERS>"
      }
    }
  }
}

{
  "type": "object",
  "properties": {}
}

{
  "type": "object",
  "required": [
    "topic",
    "value"
  ],
  "properties": {
    "topic": {
      "type": "string",
      "description": "Target topic name"
    },
    "value": {
      "type": "string",
      "description": "Message payload"
    }
  }
}

{
  "type": "object",
  "required": [
    "topic"
  ],
  "properties": {
    "topic": {
      "type": "string",
      "description": "Source topic name"
    },
    "max_messages": {
      "type": "integer",
      "description": "Maximum number of messages to read"
    }
  }
}