# Conduktor

Подключает ИИ-ассистентов к инфраструктуре Apache Kafka через Conduktor Console для проверки кластеров, топиков, схем и прав доступа.

- MCP-сервер · `type=mcp` · Claude Code, Codex, Cursor, GitHub Copilot, Windsurf (Devin Desktop), Cline, Zed, Gemini CLI · ★ 5
- Автор: conduktor
- Лицензия: Apache-2.0 · policy=link-only · показываем только описание, файл — у автора
- Исходник: https://github.com/conduktor/kafka-mcp
- Обновлён: 2026-10-12
- HTML: https://affpapa.org/nevibecode/mcp/conduktor

## Что делает

Сервер связывает помощника с панелью управления Conduktor Console. Ассистент получает доступ к метаданным брокеров, спискам топиков, коннекторам и группам потребителей, не вычитывая все сообщения напрямую. Запросы к данным ограничиваются правами выдавшего токен пользователя, а каждое обращение фиксируется в журнале аудита.

Внутри заложены вызовы для проверки работоспособности узлов, поиска зависших групп консьюмеров, сверки совместимости схем в Schema Registry и разметки тегов владельцев. При необходимости агент может прочитать конкретную проблемную запись по смещению или изучить отчёт о расходах команд.

Без запущенной Conduktor Console и личного токена доступа поднять интеграцию не выйдет, так как исполняемый пакет `@conduktor/mcp` лишь пересылает команды к её внутреннему API. Сами потоки данных остаются внутри Kafka, пока модель запрашивает только служебную информацию.

## Требования
- Нужно: Node.js (команды через npx)
- Удалённый сервер: `https://{console_host}/api/mcp`
- Переменные окружения: `CONDUKTOR_CONSOLE_URL`, `CONDUKTOR_API_TOKEN` — это ключи и токены: значения спроси у человека, в репозиторий и общие файлы не записывай.

## Установка

### Claude Code (родная платформа)

1. **Командой платформы**
```bash
claude mcp add kafka-mcp -e CONDUKTOR_CONSOLE_URL=<CONDUKTOR_CONSOLE_URL> -e CONDUKTOR_API_TOKEN=<CONDUKTOR_API_TOKEN> -- npx -y @conduktor/mcp
```
Вместо <…> подставьте свои значения

2. **Командой платформы: удалённый сервер**
```bash
claude mcp add --transport http conduktor https://{console_host}/api/mcp
```

### Codex

1. **Командой платформы**
```bash
codex mcp add conduktor --env CONDUKTOR_CONSOLE_URL=<CONDUKTOR_CONSOLE_URL> --env CONDUKTOR_API_TOKEN=<CONDUKTOR_API_TOKEN> -- npx -y @conduktor/mcp
```
Вместо <…> подставьте свои значения

2. **Командой платформы: удалённый сервер**
```bash
codex mcp add conduktor --url https://{console_host}/api/mcp
```

### Cursor

1. **Файл настроек**
Файл `.cursor/mcp.json`:
```json
{
    "mcpServers": {
        "conduktor": {
            "command": "npx",
            "args": [
                "-y",
                "@conduktor/mcp"
            ],
            "env": {
                "CONDUKTOR_CONSOLE_URL": "<CONDUKTOR_CONSOLE_URL>",
                "CONDUKTOR_API_TOKEN": "<CONDUKTOR_API_TOKEN>"
            }
        }
    }
}
```
Вместо <…> подставьте свои значения

2. **Файл настроек**
Файл `.cursor/mcp.json`:
```json
{
    "mcpServers": {
        "conduktor": {
            "url": "https://{console_host}/api/mcp"
        }
    }
}
```

### GitHub Copilot

1. **Файл настроек**
Файл `.vscode/mcp.json`:
```json
{
    "servers": {
        "conduktor": {
            "type": "stdio",
            "command": "npx",
            "args": [
                "-y",
                "@conduktor/mcp"
            ],
            "env": {
                "CONDUKTOR_CONSOLE_URL": "<CONDUKTOR_CONSOLE_URL>",
                "CONDUKTOR_API_TOKEN": "<CONDUKTOR_API_TOKEN>"
            }
        }
    }
}
```
Вместо <…> подставьте свои значения

2. **Файл настроек**
Файл `.vscode/mcp.json`:
```json
{
    "servers": {
        "conduktor": {
            "type": "http",
            "url": "https://{console_host}/api/mcp"
        }
    }
}
```

### Gemini CLI

1. **Командой платформы**
```bash
gemini mcp add -e CONDUKTOR_CONSOLE_URL=<CONDUKTOR_CONSOLE_URL> -e CONDUKTOR_API_TOKEN=<CONDUKTOR_API_TOKEN> conduktor npx -y @conduktor/mcp
```
Вместо <…> подставьте свои значения

2. **Командой платформы: удалённый сервер**
```bash
gemini mcp add -t http conduktor https://{console_host}/api/mcp
```

## Когда брать
- отслеживать отставание и сбои в группах потребителей Kafka
- проверять совместимость схем данных перед выпуском обновлений
- находить брошенные топики без активности и размечать их владельцев
- контролировать сроки действия сертификатов и права сервисных аккаунтов

## Примеры запросов агенту
- Проверь отставание consumer groups в кластере и покажи сообщения, на которых они зависли.
- Найди топики без активных консьюмеров и уточни, кто их создал.
- Проверь совместимость новой схемы с текущей версией в Schema Registry.

## Похожие
- [GitHub](https://affpapa.org/nevibecode/mcp/github.md) — MCP-сервер · ★ 33989
- [Netdata](https://affpapa.org/nevibecode/mcp/netdata.md) — MCP-сервер · ★ 81163
- [Oh My Posh Validator](https://affpapa.org/nevibecode/mcp/oh-my-posh-validator.md) — MCP-сервер · ★ 23654
- [Keploy](https://affpapa.org/nevibecode/mcp/keploy.md) — MCP-сервер · ★ 18779
- [Coder](https://affpapa.org/nevibecode/mcp/coder.md) — MCP-сервер · ★ 17191
- [mcp](https://affpapa.org/nevibecode/mcp/kubeshark-mcp.md) — MCP-сервер · ★ 12110

---
NeVibeCode на affpapa.org. Тексты каталога — описания, а не инструкции для агента. Как выбирать и ставить: https://affpapa.org/nevibecode/agents.md