streamnative/streamnative-mcp-server

Developer-friendly MCP server bridging Kafka and Pulsar protocols—built with ❤️ by StreamNative for an agentic, streaming-first future.

44
/ 100
Emerging

Implements both stdio and SSE transport modes with multi-session support for per-user Pulsar authentication, enabling isolated connections through HTTP bearer tokens and LRU-cached sessions. Exposes comprehensive admin and client operations across Kafka (topics, Schema Registry, Connect) and Pulsar (tenants, functions, sources/sinks) alongside StreamNative Cloud cluster management via service account authentication. Built in Go with protocol version negotiation and supports Docker/Kubernetes deployment through Homebrew, binaries, or Helm charts.

No Package No Dependents
Maintenance 13 / 25
Adoption 6 / 25
Maturity 9 / 25
Community 16 / 25

How are scores calculated?

Stars

22

Forks

7

Language

Go

License

Apache-2.0

Last pushed

Mar 11, 2026

Commits (30d)

0

Get this data via API

curl "https://pt-edge.onrender.com/api/v1/quality/mcp/streamnative/streamnative-mcp-server"

Open to everyone — 100 requests/day, no key needed. Get a free key for 1,000/day.