Conduktor — MCP-сервер для Claude Code: что делает и как установить
Подключает ИИ-ассистентов к инфраструктуре Apache Kafka через Conduktor Console для проверки кластеров, топиков, схем и прав доступа.
claude mcp add kafka-mcp -e CONDUKTOR_CONSOLE_URL=<CONDUKTOR_CONSOLE_URL> -e CONDUKTOR_API_TOKEN=<CONDUKTOR_API_TOKEN> -- npx -y @conduktor/mcpЧто делает Conduktor
Сервер связывает помощника с панелью управления Conduktor Console. Ассистент получает доступ к метаданным брокеров, спискам топиков, коннекторам и группам потребителей, не вычитывая все сообщения напрямую. Запросы к данным ограничиваются правами выдавшего токен пользователя, а каждое обращение фиксируется в журнале аудита.
Внутри заложены вызовы для проверки работоспособности узлов, поиска зависших групп консьюмеров, сверки совместимости схем в Schema Registry и разметки тегов владельцев. При необходимости агент может прочитать конкретную проблемную запись по смещению или изучить отчёт о расходах команд.
Без запущенной Conduktor Console и личного токена доступа поднять интеграцию не выйдет, так как исполняемый пакет @conduktor/mcp лишь пересылает команды к её внутреннему API. Сами потоки данных остаются внутри Kafka, пока модель запрашивает только служебную информацию.
Какие задачи решает
- отслеживать отставание и сбои в группах потребителей Kafka
- проверять совместимость схем данных перед выпуском обновлений
- находить брошенные топики без активности и размечать их владельцев
- контролировать сроки действия сертификатов и права сервисных аккаунтов
Примеры запросов агенту
- Проверь отставание consumer groups в кластере и покажи сообщения, на которых они зависли.
- Найди топики без активных консьюмеров и уточни, кто их создал.
- Проверь совместимость новой схемы с текущей версией в Schema Registry.
Как установить Conduktor
1Командой платформы
claude mcp add kafka-mcp -e CONDUKTOR_CONSOLE_URL=<CONDUKTOR_CONSOLE_URL> -e CONDUKTOR_API_TOKEN=<CONDUKTOR_API_TOKEN> -- npx -y @conduktor/mcpВместо <…> подставьте свои значения
2Командой платформы: удалённый сервер
claude mcp add --transport http conduktor https://{console_host}/api/mcp1Командой платформы
codex mcp add conduktor --env CONDUKTOR_CONSOLE_URL=<CONDUKTOR_CONSOLE_URL> --env CONDUKTOR_API_TOKEN=<CONDUKTOR_API_TOKEN> -- npx -y @conduktor/mcpВместо <…> подставьте свои значения
2Командой платформы: удалённый сервер
codex mcp add conduktor --url https://{console_host}/api/mcp1Файл настроек
{
"mcpServers": {
"conduktor": {
"command": "npx",
"args": [
"-y",
"@conduktor/mcp"
],
"env": {
"CONDUKTOR_CONSOLE_URL": "<CONDUKTOR_CONSOLE_URL>",
"CONDUKTOR_API_TOKEN": "<CONDUKTOR_API_TOKEN>"
}
}
}
}Вместо <…> подставьте свои значения
2Файл настроек
{
"mcpServers": {
"conduktor": {
"url": "https://{console_host}/api/mcp"
}
}
}1Файл настроек
{
"servers": {
"conduktor": {
"type": "stdio",
"command": "npx",
"args": [
"-y",
"@conduktor/mcp"
],
"env": {
"CONDUKTOR_CONSOLE_URL": "<CONDUKTOR_CONSOLE_URL>",
"CONDUKTOR_API_TOKEN": "<CONDUKTOR_API_TOKEN>"
}
}
}
}Вместо <…> подставьте свои значения
2Файл настроек
{
"servers": {
"conduktor": {
"type": "http",
"url": "https://{console_host}/api/mcp"
}
}
}1Командой платформы
gemini mcp add -e CONDUKTOR_CONSOLE_URL=<CONDUKTOR_CONSOLE_URL> -e CONDUKTOR_API_TOKEN=<CONDUKTOR_API_TOKEN> conduktor npx -y @conduktor/mcpВместо <…> подставьте свои значения
2Командой платформы: удалённый сервер
gemini mcp add -t http conduktor https://{console_host}/api/mcpПо шагам, с командами для каждой платформы: Как подключить MCP-сервер: Claude Code, Codex, Cursor, VS Code, Gemini CLI и другие
Вопросы о Conduktor
Как установить Conduktor в Claude Code?
Выполните команду claude mcp add kafka-mcp -e CONDUKTOR_CONSOLE_URL=<CONDUKTOR_CONSOLE_URL> -e CONDUKTOR_API_TOKEN=<CONDUKTOR_API_TOKEN> -- npx -y @conduktor/mcp, указав URL вашей консоли и личный токен доступа.
Что делает MCP-сервер Conduktor?
Он даёт языковым моделям доступ к метаданным Kafka через Conduktor Console, позволяя исследовать топологию кластера, проверять схемы, контролировать права доступа и анализировать состояние консьюмеров.
Передаёт ли Conduktor данные сообщений модели?
По умолчанию сервер передаёт только метаданные инфраструктуры и конфигурации, поэтому тело сообщений остаётся внутри брокеров, если только агент явно не вызовет инструмент для чтения записи по смещению.
