# kafka-dataops-mcp

> Use this tool when you need to monitor and diagnose issues in your Kafka ecosystem, such as consumer lag and broker health problems, to ensure smooth data pipeline operations. It provides incident-based diagnosis logic and real-time monitoring capabilities to identify and resolve issues quickly. Ideal for DataOps teams managing large-scale Kafka deployments, it offers valuable insights to optimize performance and minimize downtime.

Canonical page: https://skillsregistry.net/skills/aguantar-kafka-mcp-server  
JSON: https://api.skillsregistry.net/v1/skills/aguantar-kafka-mcp-server

## Description

A DataOps-focused Kafka MCP server with consumer lag diagnosis and broker health monitoring, featuring incident-based diagnosis logic derived from real CDC pipeline operational experience.

## Trust

- **Trust score (0–1):** 0.70
- **Verification tier:** verified
- **Last scanned:** 2026-09-03

## Facts

- **Version:** 1.0.0
- **Skill type:** atomic
- **Execution layer:** mcp-remote
- **Runtime environment:** api
- **Category:** devops-ci
- **Updated:** 2026-09-03

## Source

- **Source listing:** [Glama](https://glama.ai/mcp/servers/ug75dm5o1b)
- **Repository:** <https://github.com/Aguantar/kafka-mcp-server>

## Use it

Resolve this record through the SkillsRegistry MCP server (no auth, read-only):

```
claude mcp add --transport http --scope user skillsregistry https://api.skillsregistry.net/mcp
```

```json
{
  "jsonrpc": "2.0",
  "id": 1,
  "method": "tools/call",
  "params": {
    "name": "get_skill",
    "arguments": {
      "slug": "aguantar-kafka-mcp-server"
    }
  }
}
```

REST: `GET https://api.skillsregistry.net/v1/skills/aguantar-kafka-mcp-server` · pull for local use: `GET https://api.skillsregistry.net/v1/skills/aguantar-kafka-mcp-server/pull`

---
SkillsRegistry indexes agent skills from public registries and GitHub. Skills we have analysed are scanned with Circle-IR and scored on six dimensions; each listing states its scan coverage. More: https://skillsregistry.net/llms.txt