function: streaming
706 products, primary matches first, then adoption-weighted; health v2 shown.
| Product | Health v2 | Stars | Maturity |
|---|---|---|---|
| kefirjs/kefir Kefir is a lightweight Reactive Programming library for JavaScript, inspired by Bacon.js and RxJS, offering observable streams and properti… | 32 | 1885 | maintenance |
| yougov/mongo-connector A Python-based pipeline tool that synchronizes data from a MongoDB cluster to target systems such as Solr, Elasticsearch, or another MongoD… | 23 | 1872 | maintenance |
| ryanmcgrath/twython Twython is a pure Python library wrapping the Twitter API, supporting both the standard REST endpoints and the streaming API, with OAuth 1 … | 23 | 1860 | maintenance |
| lanceseidman/PiCAST PiCAST is a lightweight shell/Node.js application that turns a Raspberry Pi into a Chromecast-like streaming device controlled via HTTP req… | 66 | 1795 | maintenance |
| deepch/RTSPtoWebRTC A Go service that streams RTSP camera feeds to web browsers over WebRTC using Pion, without ffmpeg or gstreamer. It serves an HTTP endpoint… | 76 | 1788 | maintenance |
| OryxProject/oryx Oryx 2 is a Java framework implementing the lambda architecture on Apache Spark and Apache Kafka, specialized for real-time large-scale mac… | 10 | 1782 | maintenance |
| benwilber/boltstream Boltstream is a self-hosted live video streaming platform combining a Django web application with nginx-rtmp for RTMP ingest and HLS playba… | 10 | 1749 | maintenance |
| stripe/veneur Veneur is a distributed, fault-tolerant metrics pipeline written in Go that implements the DogStatsD and SSF protocols. It aggregates metri… | 10 | 1743 | maintenance |
| guyijie1211/JustLive-Android An Android app that aggregates live streams from multiple Chinese platforms (Huya, Douyu, Bilibili, NetEase CC, Douyin) into a single inter… | 23 | 1741 | maintenance |
| ReactiveX/RxPHP RxPHP is the ReactiveX implementation for PHP, providing a library for composing asynchronous and event-based programs using observable str… | 62 | 1732 | maintenance |
| vanus-labs/vanus Vanus is an open-source, cloud-native, serverless message queue with built-in event processing capabilities, written in Go. It connects Saa… | 23 | 1698 | maintenance |
| bytedance/bitsail BitSail is ByteDance's open-source distributed data integration engine built on Flink, supporting batch, streaming, and incremental data sy… | 10 | 1675 | maintenance |
| staltz/callbag-basics A tiny and fast JavaScript library implementing the callbag spec, providing basic factories and operators for reactive stream and iterable … | 32 | 1652 | maintenance |
| TheCrypt0/yi-hack-v4 Custom firmware for Xiaomi Yi cameras based on the Hi3518e chipset, adding an RTSP server, SSH, FTP, web server, and MQTT motion detection … | 23 | 1638 | maintenance |
| dashbitco/flow Flow is an Elixir library for expressing parallel computations on collections, built on top of GenStage. It provides an Enum/Stream-like AP… | 76 | 1621 | maintenance |
| cgarciae/pypeln Pypeln is a Python library for building concurrent, multi-stage data pipelines using processes, threads, or asyncio tasks through a single … | 23 | 1596 | maintenance |
| siddhi-io/siddhi Siddhi is a cloud-native stream processing and complex event processing (CEP) engine that executes Streaming SQL queries to capture events … | 72 | 1590 | maintenance |
| plhery/node-twitter-api-v2 A strongly typed, dependency-free Node.js client for the Twitter API v1.1 and v2, with bundled TypeScript types for requests and responses.… | 97 | 1558 | maintenance |
| san089/goodreads_etl_pipeline An end-to-end ETL pipeline that ingests Goodreads API data into an AWS S3 data lake, transforms it with Spark on EMR, and loads it into a R… | 32 | 1542 | maintenance |
| matryer/vice Vice is a Go library that lets you use plain Go channels transparently over message queue technologies like NATS, Redis, NSQ, and Amazon SQ… | 23 | 1539 | maintenance |
| gtxaspec/wz_mini_hacks A firmware modification toolkit for Ingenic T20/T31 based Wyze IP cameras that provides root access and extra features via a micro-SD card,… | 71 | 1527 | maintenance |
| pystorm/streamparse Streamparse is a Python library and CLI toolkit for running Python code in Apache Storm topologies, letting you write spouts and bolts with… | 58 | 1505 | maintenance |
| fabiospampinato/cliflix CLIFlix is a command-line tool that searches torrent providers for a given title and streams it instantly via WebTorrent to your favorite v… | 10 | 1491 | maintenance |
| AIRLegend/aitrack AITrack is a free 6DoF head tracking application that uses a webcam and neural networks to estimate head position and rotation. It streams … | 23 | 1482 | maintenance |
| WallarooLabs/wally Wally (formerly Wallaroo) is a fast, distributed stream-processing framework written in Pony that handles distributed computing plumbing so… | 23 | 1482 | maintenance |
| ucbrise/confluo Confluo is a C++ system for real-time monitoring and analysis of data streams, supporting high-throughput concurrent writes of millions of … | 32 | 1433 | maintenance |
| damklis/DataEngineeringProject An end-to-end data engineering project that scrapes news from RSS feeds via Airflow-scheduled Python scrapers and streams them through Kafk… | 32 | 1429 | maintenance |
| weiboad/kafka-php Kafka-php is a pure PHP client library for Apache Kafka supporting producer and consumer functionality against Kafka brokers 0.8+ (consumer… | 10 | 1429 | maintenance |
| liukelin/canal_mysql_nosql_sync A demo application showing real-time synchronization of MySQL data into Redis, Memcached, and MongoDB using Alibaba's Canal binlog parser a… | 23 | 1410 | maintenance |
| moeiscool/Shinobi Shinobi CE is a free, open-source CCTV/NVR platform written in Node.js for recording and managing IP security cameras. It supports RTSP/ONV… | 23 | 1406 | maintenance |
| tiangolo/nginx-rtmp-docker A Docker image packaging Nginx with the nginx-rtmp-module to run an RTMP server for live video streaming. It is built from source and prima… | 66 | 1345 | maintenance |
| killme2008/Metamorphosis Metamorphosis (MetaQ) is a high-availability, high-performance distributed messaging middleware written in Java, originally developed at Ta… | 32 | 1329 | maintenance |
| AOL-archive/cyclops Cyclops is a functional programming library for Java 8+ providing advanced purely functional data structures, monads, monad transformers, a… | 23 | 1327 | maintenance |
| didi/DDMQ DDMQ is a distributed messaging middleware built by DiDi on top of Apache RocketMQ, offering low-latency, high-throughput, highly available… | 10 | 1316 | maintenance |
| python-streamz/streamz Streamz is a Python library for building pipelines that manage continuous streams of real-time data. It supports complex pipelines with bra… | 66 | 1303 | maintenance |
| zendesk/ruby-kafka A pure-Ruby client library for Apache Kafka providing producer and consumer APIs with support for consumer groups, batching, compression, p… | 66 | 1282 | maintenance |
| masmu/pulseaudio-dlna A lightweight Python streaming server that adds DLNA/UPnP and Chromecast support to PulseAudio on Linux. It discovers UPnP media renderers … | 32 | 1273 | maintenance |
| microsoft/Trill Trill is a high-performance, single-node, one-pass in-memory streaming analytics engine from Microsoft Research, built on a temporal data a… | 32 | 1271 | maintenance |
| 2ndQuadrant/pglogical pglogical is a PostgreSQL extension providing logical streaming replication using a publish/subscribe model, written in C. It supports sele… | 84 | 1238 | maintenance |
| BriData/DBus DBus is a Java-based data bus platform that captures incremental changes from databases (via log-based CDC) and log sources in a non-intrus… | 23 | 1214 | maintenance |
| zhihu/kids Kids is a log aggregation system written in C++ that collects and distributes messages across machines, inspired by Facebook's Scribe with … | 23 | 1214 | maintenance |
| iyear/pure-live-core A self-hosted Go server and CLI that provides a clean livestream viewing experience for platforms like Bilibili, Douyu, Huya, and Twitch, s… | 23 | 1210 | maintenance |
| robvdpol/RaceControl Race Control is an open source, unofficial F1TV desktop client for Windows written in C# on .NET. It lets users watch live and on-demand Fo… | 10 | 1199 | maintenance |
| zhimingshenjun/DD_Monitor DD_Monitor is a PyQt5-based desktop application for monitoring multiple live streams simultaneously, built around VLC playback with danmaku… | 23 | 1190 | maintenance |
| PHZ76/RtspServer A lightweight RTSP server and pusher library written in C++11. It supports H.264/H.265 video and G711A/AAC audio streaming over unicast (RT… | 23 | 1130 | maintenance |
| oeljeklaus-you/UserActionAnalyzePlatform A big data platform for e-commerce user behavior analysis built on Spark (Core, SQL, Streaming) with Java. It provides four analysis module… | 32 | 1127 | maintenance |
| ucarGroup/DataLink DataLink is a distributed, extensible data exchange platform for real-time incremental and offline full synchronization between heterogeneo… | 23 | 1120 | maintenance |
| Parsely/pykafka PyKafka is a programmer-friendly Apache Kafka client for Python offering both high-level and low-level producer/consumer APIs, optionally a… | 10 | 1120 | maintenance |
| travisjeffery/jocko Jocko is a distributed commit log service implementing the Kafka protocol in Go, with built-in coordination via Serf discovery and Raft con… | 60 | 5012 | experimental |
| alfg/docker-nginx-rtmp A Docker image packaging NGINX with the nginx-rtmp-module and FFmpeg compiled from source on Alpine Linux, preconfigured for HLS live strea… | 23 | 1108 | maintenance |
| tweetstream/tweetstream TweetStream is a Ruby library providing simple EventMachine-based access to Twitter's Streaming API. It supports sample streams, keyword tr… | 32 | 1104 | maintenance |
| iizukanao/node-rtsp-rtmp-server A Node.js streaming server that supports RTSP, RTMP (including RTMPE/RTMPT/RTMPTE), and HTTP protocols for serving H.264 video and AAC audi… | 53 | 1098 | maintenance |
| mycelial/mycelite Mycelite is a SQLite extension (implemented as a VFS proxy in Rust) that performs physical, single-writer replication by intercepting page … | 22 | 1095 | maintenance |
| max-mapper/mississippi mississippi is a Node.js library bundling useful stream utility modules (pipe, each, pipeline, duplex, through, from, to, concat, finished,… | 23 | 1086 | maintenance |
| wj596/go-mysql-transfer A standalone Go application that syncs MySQL data in real time by listening to the MySQL binlog as a fake replica. It transforms row change… | 23 | 1066 | maintenance |
| illuspas/nginx-rtmp-win32 Prebuilt Windows binaries of nginx with the nginx-rtmp-module, bundling OpenSSL, PCRE, and zlib. It provides an RTMP media server with live… | 23 | 1054 | maintenance |
| matz/streem Streem is a prototype of a stream-based concurrent scripting language created by Yukihiro Matsumoto, influenced by the shell pipeline model… | 32 | 4598 | experimental |
| rossumur/espflix ESPFLIX is an open-source video streaming set-top box that runs entirely on an ESP32 microcontroller, outputting NTSC/PAL video and audio o… | 32 | 1016 | maintenance |
| supabase/etl Supabase ETL is a high-performance Postgres logical replication engine written in Rust that performs initial table syncs and streams ongoin… | 70 | 2322 | experimental |
| rajasekarv/vega Vega (formerly native_spark) is a from-scratch reimplementation of Apache Spark's distributed data processing engine written in Rust. It ai… | 32 | 2229 | experimental |
| nubskr/walrus Walrus is a distributed log streaming engine written in Rust, built on a high-performance write-ahead-log storage engine with segment-based… | 62 | 1923 | experimental |
| jephersonRD/Maquina-V5 A collection of Google Colab notebooks and scripts that spin up a temporary cloud gaming PC with an NVIDIA Tesla T4 GPU, install Steam, and… | 50 | 1763 | experimental |
| nestrilabs/nestri Nestri is an open-source cloud gaming platform that runs games and apps inside hardware-accelerated micro-VMs and streams them to clients o… | 60 | 1737 | experimental |
| sandglass/sandglass Sandglass is a distributed, horizontally scalable, persistent message queue that orders messages by time. It supports asynchronous task exe… | 10 | 1523 | experimental |
| kkyon/botflow Botflow is a Python dataflow programming framework for building data pipelines using pipes and routes, with parallelism via coroutines and … | 62 | 1196 | experimental |
| zknill/sqledge SQLedge replicates a Postgres database to a local SQLite file using Postgres logical replication, serving reads from SQLite while forwardin… | 28 | 1041 | experimental |
| robinhood/faust Faust is a Python stream processing library that ports the ideas of Kafka Streams to Python, using asyncio for high-performance distributed… | 23 | 6825 | abandoned |
| facebookarchive/scribe Scribe is a server for aggregating log data streamed in real time from a large number of clients, designed to be scalable and reliable. It … | 10 | 3908 | abandoned |
| alibaba/jstorm JStorm was Alibaba's enterprise stream processing engine, a Java-based distributed real-time computation framework compatible with Apache S… | 10 | 3871 | abandoned |
| apache/incubator-heron Apache Heron is a realtime, distributed, fault-tolerant stream processing engine originally developed at Twitter as a successor to Apache S… | 10 | 3628 | abandoned |
| superstreamlabs/memphis Memphis.dev is a scalable, developer-friendly data streaming platform and message broker for building event-driven and real-time applicatio… | 54 | 3439 | abandoned |
| mozilla-services/heka Heka is a Go-based tool for collecting data from many sources, performing in-flight processing, and delivering results to multiple destinat… | 10 | 3394 | abandoned |
| erdewit/ib_insync A Python library providing a sync and asyncio-based framework for the Interactive Brokers Trader Workstation API, making it easy to connect… | 10 | 3284 | abandoned |
| shyiko/mysql-binlog-connector-java A Java library for reading MySQL binary logs, both from binlog files and by tapping into the live MySQL replication stream. It supports GTI… | 23 | 2269 | abandoned |
| dominictarr/event-stream EventStream is a Node.js library for composing pipelines of event streams using functional operations like map, filter, split, and merge. I… | 10 | 2175 | abandoned |
| twitter/summingbird Summingbird is a Scala library for writing MapReduce aggregation programs that look like native collection transformations and run on distr… | 10 | 2123 | abandoned |
| nurdism/neko n.eko is a self-hosted virtual browser that streams a remote desktop running inside a Docker container to multiple viewers via WebRTC, insp… | 10 | 2077 | abandoned |
| onyx-platform/onyx Onyx is a masterless, fault-tolerant distributed computation system written in pure Clojure that supports both batch and stream processing … | 10 | 2051 | abandoned |
| airsonic/airsonic Airsonic is a free, web-based media streamer for personal music (and video) collections, forked from Subsonic via Libresonic. It supports o… | 10 | 2045 | abandoned |
| Tencent/TubeMQ TubeMQ was Tencent's high-performance message queue, donated to the Apache Software Foundation in 2019 and renamed Apache InLong. This repo… | 23 | 1996 | abandoned |
| cDima/Aerial A Windows screen saver that reproduces the Apple TV aerial-view screen saver, streaming Apple's aerial videos of cities and landscapes. It … | 23 | 1980 | abandoned |
| mattgallagher/AudioStreamer An Objective-C class for streaming audio playback over HTTP on Mac OS X and iPhone OS, written by Matt Gallagher for his Cocoa with Love bl… | 32 | 1943 | abandoned |
| facebookarchive/LogDevice LogDevice is a scalable, fault-tolerant distributed log storage system written in C++ by Facebook, storing append-only record streams repli… | 10 | 1901 | abandoned |
| polygraphene/ALVR ALVR (Air Light VR) is an open-source remote VR display that streams SteamVR output from a gaming PC to standalone headsets like Gear VR, O… | 10 | 1844 | abandoned |
| torodb/stampede ToroDB Stampede replicates data from a MongoDB replica set into relational tables in PostgreSQL, translating the document structure into no… | 23 | 1757 | abandoned |
| discoproject/disco Disco is an open-source distributed MapReduce framework written in Erlang with a Python job API, originally developed at Nokia Research Cen… | 32 | 1630 | abandoned |
| stripe-archive/mosql MoSQL is a Ruby tool that streams the contents of a MongoDB cluster into PostgreSQL, using an oplog tailer to keep the SQL mirror continuou… | 10 | 1616 | abandoned |
| alibaba/mdrill Mdrill is an open-source distributed OLAP (online analytical processing) engine from Alibaba's AdMom team, built in Java on top of JStorm/H… | 10 | 1543 | abandoned |
| jgh-/VideoCore-Inactive VideoCore is a C++ library providing an audio and video manipulation and streaming graph for building live broadcast pipelines (camera/micr… | 10 | 1465 | abandoned |
| compose/transporter Transporter is a Go CLI tool that syncs and transforms data between persistence engines such as MongoDB, PostgreSQL, Elasticsearch, MySQL, … | 10 | 1441 | abandoned |
| uber-archive/cherami-server Cherami is a distributed, scalable, durable, and highly available message queue system developed at Uber for transporting asynchronous task… | 10 | 1406 | abandoned |
| dz0ny/leapcast Leapcast is a Python application that emulates a Google ChromeCast receiver, allowing any device to receive casts from Chrome browsers and … | 10 | 1402 | abandoned |
| nytlabs/streamtools Streamtools is a graphical toolkit from The New York Times R&D Lab for exploring, analyzing, and modifying streams of real-time data. Users… | 23 | 1312 | abandoned |
| bitcoinvsalts/node-binance-trader Node Binance Trader (NBT) is a TypeScript framework for building cryptocurrency trading strategies and managing portfolios on the Binance e… | 23 | 1225 | abandoned |
| uber-archive/AthenaX AthenaX is a SQL-based streaming analytics platform open sourced by Uber, built on Apache Flink and Apache Calcite. It lets users run produ… | 10 | 1223 | abandoned |
| hydro-project/fluent Fluent was a data-driven compute platform from UC Berkeley's RISE Lab, combining an elastic cloud-native key-value store (based on Anna) wi… | 10 | 1212 | abandoned |
| killrweather/killrweather KillrWeather is a Scala reference application demonstrating integration of Apache Spark Streaming, Apache Kafka, Apache Cassandra, and Akka… | 32 | 1178 | abandoned |
| eventql/eventql EventQL is a distributed, columnar SQL database written in C++ for large-scale data collection and analytics, supporting streaming writes, … | 23 | 1176 | abandoned |
| open-webrtc-toolkit/owt-server Open WebRTC Toolkit Media Server (formerly MediaServer) is a scalable SFU+MCU server for WebRTC video conferencing and streaming, with real… | 10 | 1156 | abandoned |
| spring-attic/spring-cloud-dataflow Spring Cloud Data Flow is a microservices-based toolkit for orchestrating streaming and batch data processing pipelines built from Spring B… | 10 | 1140 | abandoned |