streamnative/streamnative-mcp-server

Developer tools

이 페이지는 AI로 자동 번역되었습니다. 기술적인 세부 사항은 원문을 확인하세요. 원문 보기

24 stars 7 forks 품질 79 트렌드 18Apache-2.0

Repository Install

개발자 친화적 인 MCP 서버 브리징 Kafka 및 Pulsar 프로토콜 - ❤️ 에이전트, 스트리밍 첫 번째 미래에 대한 스트림으로 구축.

개요

StreamNative Cloud 리소스와 Apache Kafka/Pulsar 메시징 시스템을 사용하여 AI 에이전트를 통합하기위한 모델 콘텍스 프로토콜 (MCP) 서버. StreamNative의 MCP Server는 LLM(Large Language Models) 및 AI Agent의 표준 인터페이스를 제공하여 StreamNative Cloud 서비스, Apache Kafka 및 Apache Pulsar와 상호 작용합니다. 이 구현은 표준 인터페이스를 통해 메시징 서비스에 액세스하는 AI 응용 프로그램을 가능하게하는 모델 Context 프로토콜 사양을 따릅니다. 서버는 현재 MCP 프로토콜 버전 2025-11-25, 2025-06-18, 2025-03-26 및 2024-11-05를 협상합니다. 기본 설정은 2025-11-25이며, 이전 클라이언트는 프로토콜 협상을 통해 지원됩니다.

개요(AI 번역)

StreamNative Cloud 리소스와 Apache Kafka/Pulsar 메시징 시스템을 사용하여 AI 에이전트를 통합하기위한 모델 콘텍스 프로토콜 (MCP) 서버.

개요

StreamNative의 MCP Server는 LLM(Large Language Models) 및 AI Agent의 표준 인터페이스를 제공하여 StreamNative Cloud 서비스, Apache Kafka 및 Apache Pulsar와 상호 작용합니다. 이 구현은 표준 인터페이스를 통해 메시징 서비스에 액세스하는 AI 응용 프로그램을 가능하게하는 모델 Context 프로토콜 사양을 따릅니다.

서버는 현재 MCP 프로토콜 버전 2025-11-25, 2025-06-18, 2025-03-26] 및 2024-11-05를 협상합니다. 기본 설정은 2025-11-25이며, 이전 클라이언트는 프로토콜 협상을 통해 지원됩니다.

특징

StreamNative Cloud 통합:
StreamNative Cloud 리소스에 연결
귀하의 조직에서 클러스터로 전환
클러스터 리소스의 상태를 설명
**Apache Kafka 지원 **: Apache Kafka 리소스와 상호 작용:
Kafka 관리자 운영 (토닉스, 파티션, 소비자 그룹)
Schema Registry 운영
Kafka 연결 작업 (*)
Kafka 클라이언트 운영 (전문가, 소비자)

이 페이지는 AI로 자동 번역되었습니다. 기술적인 세부 사항은 원문을 확인하세요.

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

GitHub에서 전체 README 보기

설치

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}"
      ]
    }
  }
}