StreamNativeクラウドリソースとApache Kafka/PulsarメッセージングシステムでAIエージェントを統合するためのモデルコンテキストプロトコル(MCP)サーバー。

概要

ストリームネイティブ MCP Server は、LLM (大言語モデル) および AI エージェントが StreamNative Cloud サービス、Apache Kafka、Apache Pulsar とやり取りするための標準的なインターフェイスを提供します。 この実装は、モデルコンテキストプロトコルの仕様に従い、AIアプリケーションが標準化されたインターフェースを介してメッセージングサービスにアクセスできるようにします。

現在、MCP プロトコルのバージョン 2025-11-25, 2025-06-18, [2025-03-26], [2024-11-05] を交渉しているサーバです。 デフォルト設定は2025-11-25です。ただし、古いクライアントはプロトコル交渉によってサポートされます。

##特徴

• StreamNative Cloud Integration:
• StreamNativeクラウドリソースと認証を接続
• あなたの組織で利用可能なクラスターに切り替える
• クラスターリソースのステータスを記述する
• Apache Kafka Support:Apache Kafka リソースとの相互作用:
• カフカ管理者業務(トピック、パーティション、コンシューマーグループ)
• スキーマレジストリの操作
• カフカコネクト操作(*) ・カフカクライアント業務(プロデューサー、消費者)

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