SkillFoxx

Начните вводить название, задачу или сервис

Confluent MCP Server

MCP-сервер Confluent для Kafka: топики, сообщения, Flink SQL, Schema Registry и коннекторы

MCP-серверВысокий риск

confluentinc/mcp-confluentАвтор: Confluent

Установка

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 по всем топикам и прочитай последние пять сообщений из orders

Ограничения

Нужен Node.js 22.19 или новее и доступ к Kafka или аккаунт Confluent Cloud с ключами или входом по OAuth. Это проект с поддержкой сообщества: Confluent не дает по нему гарантий. Часть инструментов Cloud пока работает только со статическими ключами. Доступность Confluent Cloud из России не проверена, локальный Kafka работает без ограничений.

Как отключить. Удалите сервер из конфигурации MCP клиента. Ключи Confluent Cloud можно отозвать в консоли.

MCP

Транспорт
stdio
Авторизация
API-ключ

Проверка безопасности

  • Может удалять топики, схемы и коннекторы
  • Отправляет сообщения в кластеры, в том числе боевые

Коротко о README

README начинается с быстрого старта через npx: сгенерировать config.yaml и запустить сервер. Инструменты сгруппированы по доступности: всегда доступные, для Confluent Cloud и для локальных развертываний. Описаны работа с Confluent Platform, TLS с внутренними сертификатами, вход по OAuth и настройка клиентов. Проект под лицензией MIT, поддержка силами сообщества.

Частые вопросы

Работает ли без Confluent Cloud?

Да, с локальным Kafka и Schema Registry доступны инструменты для топиков, сообщений, групп и схем.

Как узнать, какие инструменты включены?

Команда npx -y @confluentinc/mcp-confluent --list-tools или инструмент explain-disabled-tools.

Выбор редакции

166 скиллов для научных задач: биоинформатика, хемоинформатика, клинические данные, геоданные и доступ к 100+ базам

СкиллСредний риск44,9 тыс.
Выбор редакции

Открытый MCP-сервер Google для баз данных: готовые инструменты для Postgres, MySQL, BigQuery, Spanner и других, плюс свои инструменты в tools.yaml

MCP-серверВысокий риск16,4 тыс.
Выбор редакции

Официальные скиллы Hugging Face: работа с Hub через CLI hf, датасеты, обучение моделей, Spaces, оценка и деплой

СкиллВысокий риск11 тыс.
Выбор редакции

Экономный по токенам MCP-сервер для PostgreSQL, MySQL, MariaDB, SQL Server и SQLite с режимом только для чтения

MCP-серверВысокий риск3,5 тыс.