Open-source streaming software
730 open-source libraries, tools and applications tagged streaming, ranked by how closely streaming is their primary purpose, then by adoption and maintenance health. Each entry links to a page with sources, use cases and when to choose or avoid it.
730 products, primary matches first, then adoption-weighted; health v2 shown.
| Product | Health v2 | Stars | Maturity |
|---|---|---|---|
| influxdata/kapacitor Kapacitor is an open-source framework for processing, monitoring, and alerting on time series data, part of the InfluxData TICK stack. It u… | 95 | 2376 | maintenance |
| staltz/xstream xstream is a small, fast functional reactive stream library for JavaScript, written in TypeScript, with only 26 core operators and factorie… | 32 | 2370 | maintenance |
| filoe/cscore CSCore is a free .NET audio library written entirely in C#, offering playback, recording, encoding/decoding of many codecs, and realtime au… | 66 | 2365 | maintenance |
| muammar/mkchromecast Mkchromecast is a Python application that casts audio and video from macOS or Linux desktops to Google Cast devices (Chromecast) and Sonos … | 65 | 2349 | maintenance |
| ranaroussi/qtpylib QTPyLib is an event-driven algorithmic trading library in Python supporting backtesting, paper, and live trading via Interactive Brokers. I… | 10 | 2266 | maintenance |
| twitter-archive/distributedlog Apache DistributedLog is a high-throughput, low-latency replicated log service offering durability, replication, and strong ordering guaran… | 10 | 2202 | maintenance |
| binaryjs/binaryjs BinaryJS is a Node.js library that provides easy binary websocket streaming between a Node server and browser clients. It wraps websocket c… | 32 | 2188 | maintenance |
| francoispqt/gojay GoJay is a high-performance JSON encoder/decoder library for Go that avoids reflection by using small interfaces, with support for stream d… | 23 | 2135 | maintenance |
| dotnet/spark .NET for Apache Spark provides high-performance C# and F# bindings for Apache Spark, exposing DataFrames, SparkSQL, and Structured Streamin… | 74 | 2095 | maintenance |
| muhku/FreeStreamer FreeStreamer is an Objective-C streaming audio player library for iOS and OS X with a low-memory footprint. It supports HTTP and ShoutCast … | 32 | 2093 | maintenance |
| bytewax/bytewax Bytewax is a Python-first framework with a Rust-based distributed engine for stateful event and stream processing, inspired by Apache Flink… | 68 | 2056 | maintenance |
| runner365/LiveVideoCoreSDK LiveVideoCoreSDK is an iOS-based live video streaming SDK (built on the open-source videocore project) for RTMP push broadcasting from mobi… | 32 | 2049 | maintenance |
| DTStack/flinkStreamSQL FlinkStreamSQL is a Java framework built on Apache Flink that extends Flink's real-time SQL with custom create table/view/function syntax a… | 23 | 2045 | maintenance |
| Netflix Plugin for Kodi A Kodi add-on that provides Netflix video browsing and playback via InputStream-based DRM integration. It supports profiles, My List, libra… | 63 | 2034 | maintenance |
| mafintosh/torrent-stream torrent-stream is a low-level Node.js streaming torrent client that exposes files inside a torrent as readable streams, downloading pieces … | 32 | 1974 | maintenance |
| Groove Basin Groove Basin is a self-hosted music player server with a responsive web-based client, designed to run on a machine connected to speakers. I… | 32 | 1963 | maintenance |
| monix/monix Monix is a high-performance Scala and Scala.js library for composing asynchronous, event-based programs, offering data types like Observabl… | 84 | 1929 | maintenance |
| dominictarr/JSONStream JSONStream is a Node.js streaming JSON parser that lets you pipe raw streams through JSONStream.parse() to emit parsed objects. It supports… | 10 | 1927 | maintenance |
| openairplay/open-airplay A collection of libraries implementing Apple's AirPlay protocol, primarily a Java library with a PHP variant, usable programmatically or fr… | 23 | 1890 | maintenance |
| kefirjs/kefir Kefir is a lightweight Reactive Programming library for JavaScript, inspired by Bacon.js and RxJS, offering observable streams and properti… | 32 | 1887 | maintenance |
| 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 | 1871 | maintenance |
| 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 | 1857 | 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… | 74 | 1791 | 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… | 62 | 1791 | 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 | 1748 | 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 |
| ReactiveX/RxPHP RxPHP is the ReactiveX implementation for PHP, providing a library for composing asynchronous and event-based programs using observable str… | 56 | 1732 | maintenance |
| JustLive An Android app that aggregates live streams from multiple Chinese platforms (Huya, Douyu, Bilibili, NetEase CC, Douyin) into a single inter… | 23 | 1728 | 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 | 1674 | 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 | 1640 | 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… | 75 | 1623 | 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 | 1600 | 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 … | 66 | 1593 | 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.… | 91 | 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 | 1545 | 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 | 1541 | 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,… | 67 | 1533 | maintenance |
| streamparse Streamparse is a Python library and CLI toolkit for running Python code in Apache Storm topologies, letting you write spouts and bolts with… | 54 | 1503 | 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 | 1496 | 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 | 1492 | maintenance |
| WallarooLabs/wally Wally (formerly Wallaroo) is a fast, distributed stream-processing framework written in Pony that handles distributed computing plumbing so… | 65 | 1483 | 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 | 1440 | 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 … | 74 | 1431 | 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 | 1427 | 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 | 1411 | 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 | 1408 | 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 | 1359 | 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 | 1325 | 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 | 1314 | 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… | 75 | 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… | 65 | 1281 | 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 | 1274 | maintenance |
| 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… | 81 | 1240 | 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 | 1213 | 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 | 1212 | 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 | 1209 | 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 | 1196 | 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 | 1185 | 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 | 1133 | 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 | 1132 | 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 |
| ucarGroup/DataLink DataLink is a distributed, extensible data exchange platform for real-time incremental and offline full synchronization between heterogeneo… | 23 | 1118 | 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… | 57 | 5009 | experimental |
| FFmpeg Commander A Docker image packaging NGINX with the nginx-rtmp-module and FFmpeg compiled from source on Alpine Linux, preconfigured for HLS live strea… | 23 | 1109 | 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 | 1103 | 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… | 49 | 1097 | maintenance |
| mycelial/mycelite Mycelite is a SQLite extension (implemented as a VFS proxy in Rust) that performs physical, single-writer replication by intercepting page … | 23 | 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 | 1085 | 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… | 99 | 1057 | 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 | 4595 | 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 | 1019 | 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 | 2336 | 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… | 47 | 2336 | 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… | 57 | 1933 | 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… | 91 | 1752 | experimental |
| sandglass/sandglass Sandglass is a distributed, horizontally scalable, persistent message queue that orders messages by time. It supports asynchronous task exe… | 10 | 1524 | experimental |
| kkyon/botflow Botflow is a Python dataflow programming framework for building data pipelines using pipes and routes, with parallelism via coroutines and … | 58 | 1193 | experimental |
| zknill/sqledge SQLedge replicates a Postgres database to a local SQLite file using Postgres logical replication, serving reads from SQLite while forwardin… | 29 | 1043 | 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 | 6823 | 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 | 3906 | abandoned |
| alibaba/jstorm JStorm was Alibaba's enterprise stream processing engine, a Java-based distributed real-time computation framework compatible with Apache S… | 10 | 3867 | 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 | 3624 | abandoned |
| superstreamlabs/memphis Memphis.dev is a scalable, developer-friendly data streaming platform and message broker for building event-driven and real-time applicatio… | 51 | 3445 | 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 |
| 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 | 3283 | 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 | 2266 | 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 | 2172 | abandoned |
| twitter/summingbird Summingbird is a Scala library for writing MapReduce aggregation programs that look like native collection transformations and run on distr… | 10 | 2121 | 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 | 2076 | abandoned |
| Onyx Onyx is a masterless, fault-tolerant distributed computation system written in pure Clojure that supports both batch and stream processing … | 10 | 2050 | abandoned |
| Airsonic Airsonic is a free, web-based media streamer for personal music (and video) collections, forked from Subsonic via Libresonic. It supports o… | 10 | 2044 | 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 | 1995 | 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 | 1979 | abandoned |