# StreamNative MCP server

> Lets AI agents manage StreamNative Cloud, Apache Kafka, and Apache Pulsar messaging resources such as topics, schemas, and consumer groups.

- Repository: https://github.com/streamnative/streamnative-mcp-server
- Page: https://hostedmcp.org/servers/streamnative/streamnative-mcp-server
- Transport: —
- Stars: 24
- License: Apache-2.0

## Environment variables

| Name | Required | Secret | Description |
|---|---|---|---|
| `SNMCP_KEY_FILE` | no | no |  |
| `SNMCP_ORGANIZATION` | no | no |  |

## Tools (32)

- `all`
- `all-kafka`
- `kafka-admin`
- `kafka-client`
- `kafka-admin-topics`
- `kafka-admin-partitions`
- `kafka-admin-groups`
- `kafka-admin-schema-registry`
- `kafka-admin-connect`
- `all-pulsar`
- `pulsar-admin`
- `pulsar-client`
- `pulsar-admin-brokers`
- `pulsar-admin-brokers-status`
- `pulsar-admin-broker-stats`
- `pulsar-admin-clusters`
- `pulsar-admin-functions-worker`
- `pulsar-admin-namespaces`
- `pulsar-admin-namespace-policy`
- `pulsar-admin-ns-isolation-policy`
- `pulsar-admin-packages`
- `pulsar-admin-resource-quotas`
- `pulsar-admin-schemas`
- `pulsar-admin-subscriptions`
- `pulsar-admin-tenants`
- `pulsar-admin-topics`
- `pulsar-admin-sinks`
- `pulsar-admin-functions`
- `pulsar-admin-sources`
- `pulsar-admin-topic-policy`
- `streamnative-cloud`
- `functions-as-tools`

## FAQ

### What is StreamNative MCP Server?

It is a Model Context Protocol server that lets LLMs and AI agents interact with StreamNative Cloud services, Apache Kafka, and Apache Pulsar through a standardized interface.

### How do I install streamnative-mcp-server?

You can install it with Homebrew, a Docker image, a Helm chart on Kubernetes, a GitHub release binary, or by building from source.

### Can it connect to an external Kafka cluster?

Yes, using the --use-external-kafka flag with bootstrap servers and optional SASL/TLS and Schema Registry settings.

### How does authentication work with StreamNative Cloud?

You authenticate using a service account key file passed with --organization and --key-file flags.

### Does it support running as an HTTP server?

Yes, it offers an SSE server mode started with the sse command, configurable via --http-addr and --http-path.