# kafka-mcp

> Use this tool when you need to manage and inspect Apache Kafka topics and consumer groups, or safely reset and rewind offsets. It provides an interface for LLM agents to input topic and group names, and output topic information, consumer group details, and offset management results. Ideal for use cases requiring Kafka cluster monitoring, debugging, and maintenance, allowing for efficient troubleshooting and data stream management.

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

## Description

MCP server for Apache Kafka that allows LLM agents to inspect topics, consumer groups, and safely manage offsets (reset, rewind).

## Trust

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

## Facts

- **Version:** 1.0.0
- **Skill type:** atomic
- **Execution layer:** mcp-remote
- **Runtime environment:** api
- **Category:** ai-ml
- **Updated:** 2026-09-19

## Source

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

## 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": "wklee610-kafka-mcp"
    }
  }
}
```

REST: `GET https://api.skillsregistry.net/v1/skills/wklee610-kafka-mcp` · pull for local use: `GET https://api.skillsregistry.net/v1/skills/wklee610-kafka-mcp/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