Danfo.js is an open source, JavaScript library providing high performance, intuitive, and easy to use data structures for manipulating and processing structured data.

equivalent to kafka-streams 🐙 for nodejs ✨🐢🚀✨

JavaScript library to handle media streams on the command line (Node.js) and in the browser.

Turns XLSX into a readable stream.

Scramjet Transform Hub (STH) is a runtime supervisor that can run data processing programs called Sequences and manage local resources on any Linux server, Docker on small edge servers, and even large-scale Kubernetes clusters in the cloud or datacenters. It connects to Scramjet Spaces in Scramjet Cloud Platform.

Massively real-time traffic streaming application

Simple shared surface streaming application

Web Application Message Async Server and WAMP/MQTT bridge

Open-source eKuiper Manager UI - The first community-driven web interface for LF Edge eKuiper

Tools for building function graphs

Async parallel stream for Node.js

FlowtraceX Core Platform — a Docker-first Network Detection & Response (NDR) engine for flow-level visibility, real-time detection, and correlation.

A lightweight TypeScript library for tabular data manipulation, inspired by Python's pandas. Supports DataFrame/Series APIs and works in both Node.js and the browser.

Web application framework built on 1e14

Get the size of a stream and abort it if threshold is reached

Real-time data pipeline streaming sensor readings through Kafka and Spark to a live React dashboard. Built to learn distributed streaming systems, big data processing, and end-to-end data engineering.

Write Flink streaming pipelines as composable JSX components. Synthesizes to Flink SQL + Kubernetes FlinkDeployment CRDs.

Video upload and playback stream with NextJS

A utility to pipe a Readable through an external process and collect the output into a fresh Readable