agentmods.dev

streamnative-mcp-server CLAUDE.md

Repository instructions for StreamNative's MCP server, a program that lets AI agents communicate with Apache Kafka, Apache Pulsar, and StreamNative Cloud. They describe how to build, test, package, and understand the server.

In plain words
What is it for?
Building Docker images, running race-detection tests, checking licenses, and tracing requests through the server.
Why use it?
They give the agent the project context and correct commands, reducing guesswork when changing the code.

Instructions file

24 19d ago A scan 2,639 tokens original Apache-2.0
View the source file streamnative/streamnative-mcp-server
Install

Getting it into your agent

One page per mod, every tool's command on it. A separate URL per tool would split the same page into five that compete with each other.

agentmods
npx agentmods add instructions/streamnative/streamnative-mcp-server/claude-md
Clone the repo
git clone --depth 1 https://github.com/streamnative/streamnative-mcp-server
Per session 2,639 This file is loaded in full into every session.
When invoked 2,639 The same file — it is already loaded in full.
Security scan A 0 findings. Scan, not verified.
Origin original No closer match found in the catalogue.
Token cost

What it costs to keep this loaded

Counted locally with the o200k_base tokenizer, which is exact for GPT models; Claude uses its own tokenizer and its counts differ. Treat this as one consistent yardstick across the catalogue rather than a bill. Prices are per million input tokens.

ModelPer sessionOnce invoked
Fable 5 $0.02639 $0.02639
Opus 5 $0.01319 $0.01319
Sonnet 5 $0.00528 $0.00528
Haiku 4.5 $0.00264 $0.00264

Measured 2d ago against content hash dc6cf6d6dbc9, method: parsed. Prices are Anthropic first-party input rates as of 2026-08-30, from the pricing page.

Security

Grade A, and why

streamnative-mcp-server CLAUDE.md scanned grade A with 0 findings against 26 rules in 11 categories — prompt injection, anti-refusal, data exfiltration, privilege escalation, supply chain, agent snooping, system-prompt leakage, SSRF and excessive agency — measured 2d ago.

A static scan of the body, not an audit. Every finding is printed with the line that produced it so you can judge whether it matters here. A mod is markdown that instructs an agent; that is exactly why what it instructs is worth reading.

Nothing flagged

None of the 26 patterns this scan looks for appear in this file: no shell pipes, no recursive deletes, no credential paths, no hidden text, no instruction-override or anti-refusal phrasing, no agent-config snooping. That is not a guarantee, it is the absence of the things that are checkable.

CLAUDE.md · 248 lines

How it starts

The opening of the file, as written. The whole thing — 248 lines — stays where its author put it; the contents beside it link to each section on GitHub.

CLAUDE.md

This file provides guidance to Claude Code (claude.ai/code) when working with code in this repository.

Build Commands

make build                  # Build server binary to bin/snmcp
make docker-build           # Build local Docker image (both streamnative/mcp-server and streamnative/snmcp tags)
make docker-build-push      # Build and push multi-platform image (linux/amd64,linux/arm64)
make docker-build-multiplatform  # Build multi-platform image locally
make docker-buildx-setup    # Setup Docker buildx for multi-platform builds
make license-check          # Check license headers
make license-fix            # Fix license headers
go test -race ./...         # Run all tests with race detection
go test -race ./pkg/mcp/builders/...  # Run specific package tests
go test -v -run TestName ./pkg/...    # Run a single test

Architecture Overview

The StreamNative MCP Server implements the Model Context Protocol using the mark3labs/mcp-go library to enable AI agents to interact with Apache Kafka, Apache Pulsar, and StreamNative Cloud resources.

Request Flow

Client Request → MCP Server (pkg/mcp/server.go)
                    ↓
              SSE/stdio transport layer (pkg/cmd/mcp/)
                    ↓
              Tool Handler (from builders)
                    ↓
              Context Functions (pkg/mcp/ctx.go)
                    ↓
              Service Client (Kafka/Pulsar/SNCloud)

Core Components

  1. Server & Sessions (pkg/mcp/server.go)

    • Server struct holds MCPServer, KafkaSession, PulsarSession, and SNCloudSession
    • Sessions provide lazy-initialized clients for each service
    • Context functions (pkg/mcp/ctx.go) inject/retrieve sessions from request context

  2. Tool Builders Framework (pkg/mcp/builders/)

    • ToolBuilder interface: GetName(), GetRequiredFeatures(), BuildTools(), Validate()
    • BaseToolBuilder provides common feature validation logic
    • ToolRegistry manages all tool builders with concurrent-safe registration
    • ToolBuildConfig specifies build parameters (ReadOnly, Features, Options)
    • ToolMetadata describes tool information (Name, Version, Description, Category, Tags)

Read the full file on GitHub · 248 lines

Changes

What this file has done since we first saw it

Hashed on every crawl. A supply-chain change to an agent config is a question of when, not whether, so the history is kept rather than the latest state alone.

  1. 2d ago First seen · 248 lines · 2,639 tokens per session scan A dc6cf6d6dbc9

Subscribe to this mod's changes

streamnative-mcp-server CLAUDE.md is an instructions file published in the GitHub repository streamnative/streamnative-mcp-server (24 stars, last pushed 19d ago), licensed Apache-2.0. It adds 2,639 tokens to every session, about $0.0132 per session on Opus 5. A static security scan graded it A with 0 findings. No closer match exists in the catalogue, so it is treated as the original; first seen 2026-08-30.

DevOps and cloudPlanningTestingapache-kafkaapache-pulsardata-streamingmcpmcp-serverstreamnative
Related

Other instructions, from other repositories

agentic-engineering-for-apache-kafka AGENTS.md

Instructions for lensesio/agentic-engineering-for-apache-kafka, covering agents.md, project overview, project structure, skill structure conventions and kafka skills.

lensesio/agentic-engineering-for-apache-kafka · 2,495 tokens

kafka-schema-reg-mcp AGENTS.md

Instructions for aywengo/kafka-schema-reg-mcp, covering development guidelines, prerequisites, quick setup, install dependencies and install dev dependencies (optional but recommended).

aywengo/kafka-schema-reg-mcp · 1,576 tokens

kafka-schema-reg-mcp CLAUDE.md

Instructions for aywengo/kafka-schema-reg-mcp, a project described as: A comprehensive Message Control Protocol (MCP) server for Kafka Schema Registry.

aywengo/kafka-schema-reg-mcp · 3 tokens

codex AGENTS.md

AGENTS.md instructions for openai/codex, covering rust/codex-rs, the codex-core crate, code review rules, crate api surface and model visible context.

openai/codex · 5,182 tokens

vscode buildNext.instructions.md

Working notes and architecture documentation for the new esbuild-based build system in build/next. Use when making changes to the new build pipeline (transpile/bundle commands, NLS plugin, source-map handling, resource copying, or self-hosting watch tasks).

microsoft/vscode · 6,785 tokens

next.js AGENTS.md

Instructions for vercel/next.js, covering next.js development guide, codebase structure, monorepo overview, core package: packages/next and other important packages.

vercel/next.js · 7,296 tokens