Stream

Connects streaming data from MQTT, Kafka, and Webhook sources with buffered Redis pipelines and real-time WebSocket relay.

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.