Confluent MCP Server
MCP-сервер Confluent для Kafka: топики, сообщения, Flink SQL, Schema Registry и коннекторы
- 168 ★ репозитория
- Последний коммит
- MIT
Широкий доступ
Почему такой уровень
- Может удалять топики, схемы и коннекторы
- Отправляет сообщения в кластеры, в том числе боевые
Установка
- Работает в
Ручная установка
npx @confluentinc/mcp-confluent --init-config
npx @confluentinc/mcp-confluent --config ./config.yamlСначала создается config.yaml, в нем заполняются только нужные блоки сервисов.
Доступ и проверки
Как мы проверяемШирокий доступИнструмент может менять данные, выполнять команды или работать с секретами.
- Может удалять топики, схемы и коннекторы
- Отправляет сообщения в кластеры, в том числе боевые
Это чужой код. Посмотрите файлы в репозитории перед установкой.
Что делает
Сервер подключает агента к Confluent Cloud, Confluent Platform или обычному Apache Kafka. Для локального Kafka доступны топики, отправка и чтение сообщений, группы потребителей и схемы. С Confluent Cloud добавляются Flink SQL и его диагностика, коннекторы Kafka Connect, теги каталога, Tableflow, метрики и расходы. Набор инструментов включается по блокам в config.yaml, а инструменты диагностики объясняют, почему какой-то инструмент недоступен.
Для кого. Для дата-инженеров и разработчиков, которые работают с Kafka и Confluent.
Подходит, если
- Нужно посмотреть топики, лаг потребителей или прочитать сообщения
- Нужно написать и отладить запрос Flink SQL
- Нужно разобраться, почему упал коннектор
Не подходит, если
- Кластер боевой, а агенту нельзя удалять топики и коннекторы
- Уже есть управляемый MCP-сервер Confluent Cloud и расширять набор не нужно
Пример запроса к агенту
Покажи лаг группы потребителей orders-service по всем топикам и прочитай последние пять сообщений из ordersMCP
- Транспорт
- stdio
- Авторизация
- API-ключ
Ограничения
Нужен Node.js 22.19 или новее и доступ к Kafka или аккаунт Confluent Cloud с ключами или входом по OAuth. Это проект с поддержкой сообщества: Confluent не дает по нему гарантий. Часть инструментов Cloud пока работает только со статическими ключами. Доступность Confluent Cloud из России не проверена, локальный Kafka работает без ограничений.
Как отключить. Удалите сервер из конфигурации MCP клиента. Ключи Confluent Cloud можно отозвать в консоли.
Частые вопросы
Работает ли без Confluent Cloud?
Да, с локальным Kafka и Schema Registry доступны инструменты для топиков, сообщений, групп и схем.
Как узнать, какие инструменты включены?
Команда npx -y @confluentinc/mcp-confluent --list-tools или инструмент explain-disabled-tools.
Обсуждение
Вопросов и отзывов пока нет.
Похожие
MCP-серверыОфициальный MCP-сервер MongoDB: запросы и агрегации к базам, управление индексами, кластерами Atlas и локальными развертываниями
MCP-сервер для доступа агента к MySQL: чтение схемы и запросы, по умолчанию только на чтение, запись включается флагами
Официальный MCP-сервер ClickHouse: агент смотрит базы и таблицы и выполняет SQL, по умолчанию только на чтение
MCP-сервер от AntV для генерации графиков и диаграмм: 25 с лишним типов визуализаций, от линий и столбцов до карт, ментальных карт и диаграмм связей
Официальный MCP-сервер Tableau: агент ищет источники данных, отправляет к ним запросы и открывает дашборды и метрики Pulse
MCP MongoDB Server (kiliczsh)
MCP MongoDB Server
MCP-сервер дает агенту запросы, агрегации и запись в MongoDB и запускается одной командой npx без установки
Коротко о README
README начинается с быстрого старта через npx: сгенерировать config.yaml и запустить сервер. Инструменты сгруппированы по доступности: всегда доступные, для Confluent Cloud и для локальных развертываний. Описаны работа с Confluent Platform, TLS с внутренними сертификатами, вход по OAuth и настройка клиентов. Проект под лицензией MIT, поддержка силами сообщества.