# Stream

> Use this tool when you need to process and relay real-time data from various sources, such as MQTT brokers, Kafka topics, and webhooks, and require features like topic filtering, alerts, and anomaly detection. It ingests data into Redis Streams and provides a WebSocket relay with backfill capabilities, making it suitable for applications that require real-time data processing and monitoring. Ideal for use cases that involve high-volume data streams, such as IoT device monitoring, log analysis, or real-time analytics.

Canonical page: https://skillsregistry.net/skills/gh-rsafaya-stream  
JSON: https://api.skillsregistry.net/v1/skills/gh-rsafaya-stream

## Description

Streaming data engine that ingests from MQTT brokers, Kafka topics, and webhooks into Redis Streams, providing real-time WebSocket relay with backfill capabilities and topic filtering. Includes server-side TypeScript watcher processes for alerts, anomaly detection, and aggregation. Comprehensive CLI for connection management, status monitoring, and log streaming.

## Trust

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

## Facts

- **Version:** 1.0.0
- **Skill type:** atomic
- **Execution layer:** mcp-remote
- **Runtime environment:** api
- **Category:** database
- **Updated:** 2026-09-02

## Source

- **Source listing:** [PulseMCP](https://www.pulsemcp.com/servers/gh-rsafaya-stream)
- **Repository:** <https://github.com/mcp-stream/mcp-stream>

## 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": "gh-rsafaya-stream"
    }
  }
}
```

REST: `GET https://api.skillsregistry.net/v1/skills/gh-rsafaya-stream` · pull for local use: `GET https://api.skillsregistry.net/v1/skills/gh-rsafaya-stream/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