Kafka MCP Server
позволяет LLM моделям взаимодействовать с Apache Kafka для операций с сообщениями, темами и мониторинга кластера.
Описание
Это сервер на Go, реализующий протокол MCP для Apache Kafka с использованием библиотек franz-go и mcp-go. Он предоставляет инструменты для производства/потребления сообщений, управления темами, мониторинга групп потребителей и оценки здоровья кластера. Поддерживает SASL и TLS для безопасности. Идеален для интеграции ИИ-приложений с Kafka, автоматизации диагностики и анализа данных в реальном времени, упрощая доступ LLM к стриминговым системам.
Возможности
Производство и потребление сообщений
Инструменты produce_message и consume_messages для отправки и получения сообщений из тем Kafka.
Управление темами
list_topics, describe_topic для перечисления и описания тем с метаданными о партициях.
Мониторинг групп потребителей
list_consumer_groups, describe_consumer_group для анализа групп и лагов.
Оценка здоровья кластера
cluster_overview, health-check для обзора состояния брокеров и партиций.
Безопасность и конфигурация
Поддержка SASL (PLAIN, SCRAM) и TLS для аутентификации и шифрования.
Установка
Установка через Homebrew (macOS/Linux): brew tap tuannvm/mcp brew install kafka-mcp-server
Из исходного кода: git clone https://github.com/tuannvm/kafka-mcp-server.git cd kafka-mcp-server go build -o kafka-mcp-server ./cmd
Пример конфигурации для Cursor или Claude (в ~/.cursor/mcp.json или аналогичном): { “mcpServers”: { “kafka”: { “command”: “kafka-mcp-server”, “args”: [], “env”: { “KAFKA_BROKERS”: “localhost:9092”, “KAFKA_CLIENT_ID”: “kafka-mcp-server”, “MCP_TRANSPORT”: “stdio” } } } } Требования: Go 1.24+, Docker для тестов, доступ к Kafka-кластеру.