# StreamNative (Apache Pulsar/Kafka)

> Use this tool when you need to manage and interact with Apache Pulsar or Kafka messaging systems through a unified interface, solving problems such as topic and subscription management, schema handling, and authentication. It accepts natural language inputs and provides outputs in standard I/O and SSE formats, making it ideal for developers and operators seeking to monitor and troubleshoot messaging infrastructure. The tool is particularly useful in contexts where streamlined management of messaging systems is required, such as in cloud-based or standalone deployments.

Canonical page: https://skillsregistry.net/skills/streamnative-pulsar-kafka  
JSON: https://api.skillsregistry.net/v1/skills/streamnative-pulsar-kafka

## Description

StreamNative MCP Server provides a bridge between AI agents and Apache Pulsar/Kafka messaging systems, enabling management of topics, subscriptions, schemas, and more through a unified interface. Developed by StreamNative, it supports both standard I/O and SSE communication protocols, offers comprehensive authentication via OAuth2, and includes specialized tools for Pulsar administration, Kafka operations, and StreamNative Cloud resource management. The server can operate in different modes (StreamNative Cloud, standalone Kafka, or standalone Pulsar) with configurable feature sets, making it particularly valuable for developers and operators who need to monitor, troubleshoot, and manage messaging infrastructure through natural language interactions.

## Trust

- **Trust score (0–1):** 0.48
- **Verification tier:** scanned
- **Last scanned:** 2026-09-28

## Facts

- **Version:** 1.0.0
- **Skill type:** atomic
- **Execution layer:** mcp-remote
- **Runtime environment:** api
- **Category:** ai-ml
- **Updated:** 2026-09-28

## Source

- **Source listing:** [PulseMCP](https://www.pulsemcp.com/servers/streamnative-pulsar-kafka)
- **Repository:** <https://github.com/streamnative/streamnative-mcp-server>

## Use it

Resolve this record through the SkillsRegistry MCP server (no auth, read-only):

```
claude mcp add --transport http --scope user skillsregistry https://api.skillsregistry.net/mcp
```

```json
{
  "jsonrpc": "2.0",
  "id": 1,
  "method": "tools/call",
  "params": {
    "name": "get_skill",
    "arguments": {
      "slug": "streamnative-pulsar-kafka"
    }
  }
}
```

REST: `GET https://api.skillsregistry.net/v1/skills/streamnative-pulsar-kafka` · pull for local use: `GET https://api.skillsregistry.net/v1/skills/streamnative-pulsar-kafka/pull`

---
SkillsRegistry indexes agent skills from public registries and GitHub. Skills we have analysed are scanned with Circle-IR and scored on six dimensions; each listing states its scan coverage. More: https://skillsregistry.net/llms.txt