streamnative/streamnative-mcp-server

Эта страница переведена автоматически. Технические детали смотрите в оригинале. Открыть оригинал

24 stars 7 forks Качество 79 Тренд 18Apache-2.0

Удобный для разработчиков MCP-сервер, соединяющий протоколы Kafka и Pulsar, созданный StreamNative для агентного, потокового будущего.

Обзор

Сервер Model Context Protocol (MCP) для интеграции агентов ИИ с ресурсами StreamNative Cloud и системами обмена сообщениями Apache Kafka/Pulsar. StreamNative MCP Сервер предоставляет стандартный интерфейс для LLM и агентов ИИ для взаимодействия с сервисами StreamNative Cloud, Apache Kafka и Apache Pulsar. Эта реализация следует спецификации Model Context Protocol, позволяя приложениям ИИ получать доступ к службам обмена сообщениями через стандартизированный интерфейс. Сервер в настоящее время ведет переговоры по версиям протоколов MCP 2025-11-25, 2025-06-18, 2025-03-26 и 2024-11-05. Предпочтение по умолчанию составляет 2025-11-25, в то время как старые клиенты по-прежнему поддерживаются путем переговоров по протоколу.

Обзор (машинный перевод)

Сервер Model Context Protocol (MCP) для интеграции агентов ИИ с ресурсами StreamNative Cloud и системами обмена сообщениями Apache Kafka/Pulsar.

Обзор

StreamNative MCP Сервер предоставляет стандартный интерфейс для LLM и агентов ИИ для взаимодействия с сервисами StreamNative Cloud, Apache Kafka и Apache Pulsar. Эта реализация следует спецификации Model Context Protocol, позволяя приложениям ИИ получать доступ к службам обмена сообщениями через стандартизированный интерфейс.

Сервер в настоящее время ведет переговоры о версиях протоколов MCP 2025-11-25, 2025-06-18, 2025-03-26 и 2024-11-05. Предпочтение по умолчанию 2025-11-25, в то время как старые клиенты остаются поддерживаемыми через переговоры по протоколу.

Особенности

StreamNative Cloud Integration: Подключение к ресурсам StreamNative Cloud с помощью аутентификации Переключение на кластеры, доступные в вашей организации
Опишите состояние ресурсов кластеров Поддержка Apache Kafka: взаимодействие с ресурсами Apache Kafka, включая:
Операции Kafka Admin (темы, разделы, группы потребителей)
Операции реестра схем
Операции Kafka Connect (*) Кафка Клиентские операции (производители, потребители)

Эта страница переведена автоматически. Технические детали смотрите в оригинале.

README

Показан фрагмент оригинального README. Открыть оригинал.

StreamNative MCP Server

A Model Context Protocol (MCP) server for integrating AI agents with StreamNative Cloud resources and Apache Kafka/Pulsar messaging systems.

Overview

StreamNative MCP Server provides a standard interface for LLMs (Large Language Models) and AI agents to interact with StreamNative Cloud services, Apache Kafka, and Apache Pulsar. This implementation follows the Model Context Protocol specification, enabling AI applications to access messaging services through a standardized interface.

The server currently negotiates MCP protocol versions 2025-11-25, 2025-06-18, 2025-03-26, and 2024-11-05. The default preference is 2025-11-25, while older clients remain supported through protocol negotiation.

Features

StreamNative Cloud Integration:
- Connect to StreamNative Cloud resources with authentication
- Switch to clusters available in your organization
- Describe the status of clusters resources
Apache Kafka Support: Interact with Apache Kafka resources including:
- Kafka Admin operations (topics, partitions, consumer groups)
- Schema Registry operations
- Kafka Connect operations (*)
- Kafka Client operations (producers, consumers)
Apache Pulsar Support: Interact with Apache Pulsar resources including:
- Pulsar Admin operations (topics, namespaces, tenants, schemas, etc.)
- Pulsar Client operations (producers, consumers)
- Functions, Sources, and Sinks management
- Read-only MCP resources for context, catalog, and bounded admin summaries
Multiple Connection Options:
- Connect to StreamNative Cloud with service account authentication
- Connect directly to external Apache Kafka clusters
- Connect directly to external Apache Pulsar clusters

*: The Kafka Connect operations are only tested and verified on StreamNative Cloud.

Installation

Homebrew (macOS and Linux)

The easiest way to install streamnative-mcp-server is using Homebrew:

# Add the tap repository
brew tap streamnative/streamnative

# Install streamnative-mcp-server
brew install streamnative/streamnative/snmcp

Docker Image

StreamNative MCP Server releases the Docker Image to streamnative/snmcp, and it can be used to run both stdio server and sse server via docker command.

# Pull image from Docker Hub
docker pull streamnative/snmcp

Helm Chart (Kubernetes)

See charts/snmcp/README.md for Helm installation via the StreamNative chart repository.

From Github Release

Visit https://github.com/streamnative/streamnative-mcp-server/releases to get the latest binary of StreamNative MCP Server.

From Source

# Clone the repository
git clone https://github.com/streamnative/streamnative-mcp-server.git
cd streamnative-mcp-server

go mod tidy
go mod download

# Build the binary
make

Usage

Prerequisites

Открыть полный README на GitHub

Установка

docker run -i --rm -e SNMCP_ORGANIZATION -e SNMCP_KEY_FILE -v ${STREAMNATIVE_CLOUD_KEY_FILE}:/key.json streamnative/snmcp stdio

Новичок в MCP? Начните с руководства на mcpskill.org →

Конфигурация

{
  "mcpServers": {
    "mcp-streamnative": {
      "command": "${PATH_TO_SNMCP}/bin/snmcp",
      "args": [
        "stdio",
        "--organization",
        "${STREAMNATIVE_CLOUD_ORGANIZATION_ID}",
        "--key-file",
        "${STREAMNATIVE_CLOUD_KEY_FILE}"
      ]
    }
  }
}