# kafka-mcp-server

> kafka-mcp-server — tuannvm-kafka-mcp-server. Use this tool when you need to manage model context in Apache Kafka, solving problems of data consistency and model synchronization across distributed systems. It provides an interface for inputs such as model updates and outputs like synchronized model states, utilizing the Model Context Protocol. Ideal for use cases requiring real-time data processing and model management in Kafka-based architectures.

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

## Description

A Model Context Protocol (MCP) server for Apache Kafka implemented in Go, leveraging franz-go and mcp-go.

## Trust

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

## Facts

- **Version:** 1.0.0
- **Skill type:** atomic
- **Execution layer:** container
- **Runtime environment:** vm
- **Updated:** 2026-09-28

## Source

- **Source listing:** [GitHub](https://github.com/tuannvm/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": "tuannvm-kafka-mcp-server"
    }
  }
}
```

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