{"id":"2fae22ec-f7bb-443b-abd6-cb38bb243d17","shortId":"Y6BZN2","kind":"mcp","title":"Stream","tagline":"Connects streaming data from MQTT, Kafka, and Webhook sources with buffered Redis pipelines and real-time WebSocket r...","description":"Connects streaming data from MQTT, Kafka, and Webhook sources with buffered Redis pipelines and real-time WebSocket relay.\n\nStreaming 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.","tags":["stream"],"capabilities":["mcp","transport-stdio","open-source"],"categories":[],"synonyms":[],"warnings":[],"endpointUrl":"https://github.com/mcp-stream/mcp-stream","protocol":"mcp","transport":"stdio","auth":{"type":"mcp","details":{"transport":"stdio"}},"qualityScore":"0.554","qualityRationale":"deterministic score 0.55 from registry signals: · indexed on pulsemcp · has source repo · 2 github stars · registry-generated description present","verified":false,"liveness":"unknown","lastLivenessCheck":null,"agentReviews":{"count":0,"score_avg":null,"cost_usd_avg":null,"success_rate":null,"latency_p50_ms":null,"narrative_summary":null,"summary_updated_at":null},"enrichmentModel":"deterministic:mcp:v1","enrichmentVersion":1,"enrichedAt":"2026-05-15T05:22:25.332Z","embedding":null,"createdAt":"2026-04-28T08:22:12.840Z","updatedAt":"2026-05-15T05:22:25.332Z","lastSeenAt":"2026-05-15T05:22:25.332Z","tsv":"'aggreg':79 'alert':75 'anomali':76 'backfil':62 'broker':47 'buffer':12,31 'capabl':63 'cli':81 'comprehens':80 'connect':2,21,83 'data':4,23,41 'detect':77 'engin':42 'filter':66 'includ':67 'ingest':44 'kafka':7,26,48 'log':88 'manag':84 'mcp' 'monitor':86 'mqtt':6,25,46 'open-source' 'pipelin':14,33 'process':73 'provid':55 'r':20 'real':17,36,57 'real-tim':16,35,56 'redi':13,32,53 'relay':39,60 'server':69 'server-sid':68 'side':70 'sourc':10,29 'status':85 'stream':1,3,22,40,54,89 'time':18,37,58 'topic':49,65 'transport-stdio' 'typescript':71 'watcher':72 'webhook':9,28,51 'websocket':19,38,59","prices":[{"id":"1e8fbdb3-89ed-4ed7-9908-01decc4c0833","listingId":"2fae22ec-f7bb-443b-abd6-cb38bb243d17","amountUsd":"0","unit":"free","nativeCurrency":null,"nativeAmount":null,"chain":null,"payTo":null,"paymentMethod":"mcp-free","isPrimary":true,"details":{"transport":"stdio"},"createdAt":"2026-04-28T08:22:12.840Z"}],"sources":[{"listingId":"2fae22ec-f7bb-443b-abd6-cb38bb243d17","source":"pulsemcp","sourceId":"https://www.pulsemcp.com/servers/gh-rsafaya-stream","sourceUrl":"https://api.pulsemcp.com/v0beta/servers","isPrimary":true,"firstSeenAt":"2026-04-28T08:22:12.840Z","lastSeenAt":"2026-05-15T05:22:25.332Z"}],"details":{"listingId":"2fae22ec-f7bb-443b-abd6-cb38bb243d17","quickStartSnippet":null,"exampleRequest":null,"exampleResponse":null,"schema":null,"openapiUrl":null,"agentsTxtUrl":null,"citations":[],"useCases":[],"bestFor":[],"notFor":[],"kindDetails":{"source":"pulsemcp","transport":"stdio","server_name":"Stream","github_stars":2,"registry_url":"https://www.pulsemcp.com/servers/gh-rsafaya-stream","source_code_url":"https://github.com/mcp-stream/mcp-stream"},"updatedAt":"2026-05-15T05:22:25.332Z"}}