Kafka MCP Server

DataOps Kafka MCP server with consumer lag diagnosis and broker monitoring

Local serverstdio

What is the Kafka MCP Server?

DataOps Kafka MCP server with consumer lag diagnosis and broker monitoring

What you get

A DataOps-focused Kafka MCP server with consumer lag diagnosis and broker health monitoring. Diagnosis logic is based on actual CDC pipeline operational experience.

  • kafka_consumer_lag — — Consumer group lag with incident-pattern diagnosis
  • kafka_topic_info — — Topic details with ISR/replication health checks
  • kafka_broker_status — — Cluster health: brokers, controller, under-replicated partitions
  • kafka_list_topics — — Topic catalog with built-in descriptions

More MCP options

Compare MCP servers by category, or browse hosted MCP servers if you prefer an endpoint over a local process.

Maintainer setup documentation.

How to install the Kafka MCP Server

{
  "mcpServers": {
    "kafka-dataops": {
      "command": "uvx",
      "args": ["kafka-dataops-mcp"],
      "env": {
        "KAFKA_BOOTSTRAP_SERVERS": "your-value"
      }
    }
  }
}

Add to claude_desktop_config.json, then restart Claude Desktop.

Configuration

VariableDescriptionRequired
KAFKA_BOOTSTRAP_SERVERSConfiguration value read at startup.Optional

Frequently asked questions

DataOps Kafka MCP server with consumer lag diagnosis and broker monitoring Confirm the tools offered by your installed version in the connected client. Tool availability and permissions depend on the server and account configuration.