How do I install Kafka Dataops?

Copy the stdio config for Cursor, Claude Desktop, Claude Code, or VS Code on this page. It uses the publisher's install, not a PlugMCP proxy.

Does Kafka Dataops need an API key?

The publisher lists these environment variables: KAFKA_BOOTSTRAP_SERVERS.

What transport does Kafka Dataops use?

Kafka Dataops runs locally over stdio.

Kafka Dataops

Q: When was Kafka Dataops last checked?

Last checked 2026-10-16. DataOps Kafka MCP server with consumer lag diagnosis and broker monitoring

by io.github.Aguantar

DataOps Kafka MCP server with consumer lag diagnosis and broker monitoring

Power your agent

Add this server

The publisher's own command. Not a PlugMCP endpoint.

Local command

uvx kafka-dataops-mcp==0.1.0

Credentials from the publisher

KAFKA_BOOTSTRAP_SERVERS — Kafka bootstrap servers

Provider

Claude Code

KAFKA_BOOTSTRAP_SERVERS=<value> claude mcp add io.github.aguantar-kafka-dataops-mcp -- uvx kafka-dataops-mcp==0.1.0

Run in a terminal.

Claude Desktop

{
  "mcpServers": {
    "io.github.aguantar-kafka-dataops-mcp": {
      "command": "uvx",
      "args": [
        "kafka-dataops-mcp==0.1.0"
      ],
      "env": {
        "KAFKA_BOOTSTRAP_SERVERS": "<value>"
      }
    }
  }
}

claude_desktop_config.json

Step-by-step: add this in Claude

Remote URL or a command on your machine? How the two installs differ

Run on PlugMCP

Host a copy with our keys and logs.

A new server you create. It is not this listing's official endpoint. Use the publisher install when you want their URL and their credentials.

Launch

Related MCP

Related skills

View all

kafka-dataops-mcp

mcp-name: io.github.Aguantar/kafka-dataops-mcp

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

Features

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

Diagnosis based on real incidents

The diagnosis logic is not generic — it's based on actual operational experience:

Flink crash detection: "no active members" + growing lag = likely Flink Job failure (based on a 46-hour outage caused by MySQL DELETE → Debezium tombstone → Flink NPE)
Checkpoint vs consumer group: warns that Kafka consumer group reset alone is insufficient for Flink — checkpoints must be deleted first
ClusterIdMismatch: detects missing brokers and suggests Docker volume conflict as root cause
ISR monitoring: ISR < min.insync.replicas = write failures (critical)

Installation

pip install kafka-dataops-mcp

Usage with Claude Code

Add to your .mcp.json:

{
  "mcpServers": {
    "kafka": {
      "command": "kafka-dataops-mcp",
      "env": {
        "KAFKA_BOOTSTRAP_SERVERS": "localhost:9092"
      }
    }
  }
}

Environment Variables

Variable	Default	Description
`KAFKA_BOOTSTRAP_SERVERS`	`localhost:9092`	Kafka bootstrap servers
`KAFKA_COMMAND_TIMEOUT`	`10`	Command timeout in seconds

License

MIT