Add real-time features to your app in minutes, not months. No Kafka, no WebSocket headaches, no infrastructure ops.
import { init, connect, stream } from "@streamflux/sdk";
init({ url: "wss://api.streamflux.dev/ws" });
await connect();
stream("orders")
.window(5, "seconds")
.on("anomaly", (event) => {
alert(event);
});StreamFlux handles the complexity so you can focus on building great products.
Sub-millisecond latency for real-time event delivery. Built for scale from day one.
Intuitive SDK with TypeScript support. Topics, windows, and filters in a few lines of code.
Built-in authentication, automatic reconnection, and production-grade reliability.
StreamFlux is the first real-time platform with native MCP (Model Context Protocol) support. Let your AI assistants monitor, analyze, and interact with your data streams.
Example: Ask your AI assistant in Cursor or Claude
"List all active topics in StreamFlux"
"Publish a test event to the orders topic"
"Create a 5-second window on user-events and analyze the data"
npx @streamflux/mcp-server