Ross ROSS = Recommend OSS · open-source software intelligence for agents

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.

ProductHealth v2StarsMaturity
Aerospike Database
Aerospike is a distributed, flash-optimized NoSQL database server written in C that combines in-memory speeds with SSD-based durability thr…
941380stable
hydro-project/hydro
Hydro is a Rust framework for building correct and performant distributed systems using location-oriented programming, where a single progr…
951379active
anyrtcIO-Community/anyRTC-RTMP-OpenSource
anyLive is an open-source cross-platform live streaming SDK from anyRTC built on a WebRTC-93 base, providing RTMP push (publishing) and RTM…
274912maintenance
develop202/migu_video
A self-hosted Node.js service that proxies and exposes China Mobile Migu Video live TV streams as playlist interfaces (e.g., interface.txt)…
591340active
ratwithacompiler/OBS-captions-plugin
An OBS Studio plugin that generates closed captions for live streams using the Google Cloud Speech Recognition API. It leverages Twitch's b…
771336active
loggie-io/loggie
Loggie is a lightweight, high-performance, cloud-native log collection agent and aggregator written in Go. It uses Kubernetes CRDs to confi…
231334active
halaxa/json-machine
JSON Machine is a PHP library for memory-efficient streaming parsing of large JSON files and streams. It provides a simple iterator-based A…
691332stable
FutunnOpen/py-futu-api
The official Python SDK for the Futu OpenAPI, providing market data and trading interfaces for Hong Kong, US, and China A-share markets via…
621321active
GoogleCloudPlatform/DataflowTemplates
A collection of Google-provided Apache Beam pipeline templates for Google Cloud Dataflow that solve common in-cloud data tasks like import/…
951317active
SkipLabs/skip
Skip is an open-source framework for building reactive backend services, featuring an incremental compute engine that automatically keeps d…
761315active
arkflow-rs/arkflow
ArkFlow is a high-performance stream processing engine written in Rust on top of Tokio, connecting configurable inputs (Kafka, MQTT, HTTP, …
681306active
apache/datafusion-comet
Apache DataFusion Comet is a high-performance accelerator plugin for Apache Spark that keeps queries Arrow-native end-to-end, executing ope…
901295active
puniverse/quasar
Quasar is a JVM library providing lightweight threads (fibers), Go-like channels, and Erlang-like actors for Java and Kotlin, using bytecod…
234551maintenance
water8394/flink-recommandSystem-demo
A real-time product recommendation system built on Apache Flink, demonstrating streaming computation of product popularity, user profiles, …
324475maintenance
Alpakka
Akka is a JVM-based platform built on the actor model for building concurrent, distributed, and resilient applications, comprising core lib…
911268active
meta-pytorch/data
TorchData is a PyTorch library providing scalable, performant data loading utilities, including StatefulDataLoader, a drop-in replacement f…
731267active
Roc
Roc Toolkit is a C library and set of command-line tools for real-time audio streaming over IP networks, with guaranteed latency, Forward E…
641257stable
Drasi
Drasi is a Data Change Processing platform that monitors data sources for changes, evaluates them against continuously running Cypher queri…
741255active
hgaiser/moonshine
Moonshine is a headless streaming host server written in Rust that lets you stream games from a Linux PC to devices running Moonlight clien…
931252active
Stock Indicators
A C# NuGet library (FacioQuo.Stock.Indicators, formerly Skender.Stock.Indicators) that transforms historical OHLCV price bars from equities…
951248active
algora-io/tv
Algora TV is an open-source interactive livestreaming and video-sharing platform for developers, built with Elixir/Phoenix. It supports RTM…
521248active
LaiFengiOS/LFLiveKit
LFLiveKit is an open-source RTMP live streaming SDK for iOS written in Objective-C. It provides H264/AAC hardware encoding, GPUImage beauty…
324383maintenance
pmacct/pmacct
pmacct is a set of multi-purpose passive network monitoring daemons written in C that collect, aggregate, replicate and export IP traffic a…
661244active
jimmywarting/StreamSaver.js
StreamSaver.js is a JavaScript library that lets browser apps write a WritableStream directly to the user's file system, saving large files…
624370maintenance
kevwan/go-stash
go-stash is a high-performance, open-source server-side data processing pipeline written in Go that ingests data from Kafka, applies config…
541225active
ttezel/twit
A Node.js client library for the Twitter API supporting both REST and Streaming endpoints. It handles OAuth authentication, posting tweets,…
324280maintenance
DuoStream/Duo
Duo is a Windows-based multiseat game streaming application that gives each user an independent virtual desktop session, built on top of Su…
831215active
uhop/stream-json
stream- is a micro-library of composable stream components for parsing, filtering, and transforming JSON and JSONC with a minimal memory fo…
751200stable
esp32cam-ready
Firmware for ESP32-CAM modules that turns the device into an RTSP streaming camera server, HTTP Motion JPEG streamer, and HTTP snapshot ima…
661196active
xataio/pgstream
pgstream is an open-source change data capture (CDC) tool and Go library that replicates PostgreSQL data, including DDL/schema changes, to …
851195active
vesaaa/vstv
VsTV is a lightweight (under 5MB) Android live TV application for smart TVs, TV boxes, tablets, and phones, supporting M3U/TXT subscription…
771195active
marsupialtail/quokka
Quokka is a lightweight distributed dataflow/query engine written in Python, built on Ray, DuckDB, Polars, and Arrow, designed for stateful…
231193active
apache/amoro
Apache Amoro (incubating) is a Lakehouse management system built on open data lake formats like Iceberg, Paimon, and Mixed-Hive. It provide…
711191active
stream-rec/stream-rec
Stream-rec is an automatic live stream recording tool built with Kotlin, Ktor, and ffmpeg. It records streams and bullet comments (danmu) f…
101190active
zhuhaichao518/cloudplayplus_stone
CloudPlayPlus is an open-source remote desktop and game streaming application built with Flutter and a customized libWebRTC, designed for l…
461171active
nzbdav-dev/nzbdav
NzbDav is a self-hosted WebDAV server that mounts NZB documents as a virtual file system, allowing streaming directly from Usenet providers…
731159active
Edgio/vflow
vFlow is a high-performance, scalable network flow collector written in pure Go that ingests IPFIX (RFC7011), sFlow v5, and Netflow v5/v9 t…
231157active
knighthat/Kreate
Kreate is an open-source Android music player that serves as a multilingual frontend for YouTube Music, forked from RiMusic with a strong e…
851154active
TrunkRecorder/trunk-recorder
Trunk Recorder is a C++ application that records calls from trunked and conventional radio systems (P25, SmartNet, DMR, analog) using one o…
841145active
roleoroleo/yi-hack-Allwinner-v2
A custom firmware modification for Xiaomi Yi 1080p cameras built on the Allwinner SoC, replacing the stock cloud-dependent software with a …
881140active
IntelMQ
IntelMQ is an open-source solution for IT security teams (CERTs, CSIRTs, SOCs) for collecting and processing security feeds using a message…
571140active
baidu/bigflow
Baidu Bigflow is a distributed computing framework offering simple, flexible Python APIs for writing data processing programs that can run …
441132active
Xinrea/bili-shadowreplay
A desktop and Docker-deployable tool that continuously caches live streams (Bilibili, Douyin, TikTok, Kuaishou) and lets users clip segment…
941130active
HiveMQ MQTT Client
HiveMQ MQTT Client is a high-performance Java client library implementing MQTT 5.0 and MQTT 3.1.1 with reactive, asynchronous, and blocking…
951125stable
alexballas/go2tv
Go2TV is a cross-platform application (with GUI and CLI modes) that casts video, audio, and image files to Smart TVs and Chromecast devices…
971120active
rxRust/rxRust
rxRust is a zero-cost, type-safe Rust implementation of Reactive Extensions (Rx) for functional reactive programming with asynchronous even…
771118active
homebridge-plugins/homebridge-camera-ffmpeg
A Homebridge plugin that exposes FFmpeg-based IP cameras to Apple HomeKit, streaming video and audio via RTSP or HTTP sources. It also supp…
521115active
manycoretech/aholo-viewer
Aholo Viewer is a high-performance TypeScript renderer for 3D Gaussian Splatting (3DGS) scenes and meshes, using a chunked streaming LOD sc…
821102active
gohangout
Gohangout is a Logstash-like data processing tool written in Go that consumes events (commonly from Kafka), applies configurable filters, a…
641101active
aiXander/Realtime_PyAudio_FFT
A low-latency Python server that captures live audio from microphone, line-in, or loopback devices and computes realtime features like band…
761084active
linkedin/databus
Databus is LinkedIn's source-agnostic distributed change data capture (CDC) system that reliably captures and streams primary data store ch…
323684maintenance
shidenggui/easyquant
Easyquant is a Python quantitative trading framework for Chinese stock markets, built on easytrader and easyquotation with an event engine …
343679maintenance
jeffbass/imagezmq
imageZMQ is a set of Python classes that transport OpenCV images between computers using PyZMQ messaging. It enables distributed computer v…
581073stable
ufal/whisper_streaming
A Python library that turns Whisper-like speech recognition models into a real-time streaming transcription and translation system using a …
503674maintenance
SwarmCloud P2P Engine (CDNBye)
A JavaScript library that layers a WebRTC datachannel-based peer-to-peer network on top of hls.js, letting viewers share HLS video segments…
481072active
Project Lightspeed
A self-contained live streaming server written in Rust that ingests OBS streams via the FTL protocol and delivers them to browsers over Web…
323662maintenance
lensesio/stream-reactor
Stream Reactor is a collection of Apache 2.0 licensed Kafka Connect sinks and sources maintained by Lenses.io since 2016. It provides conne…
981069active
spring-cloud/spring-cloud-stream
Spring Cloud Stream is a Java framework for building event-driven microservices connected via messaging systems like Kafka and RabbitMQ. It…
911069active
segler-alex/RadioDroid
RadioDroid is an Android app for discovering and streaming internet radio stations using the community-driven radio-browser.info directory.…
231066active
apache/artemis
Apache Artemis is a multi-protocol, high-performance message broker supporting AMQP 1.0, MQTT 3.1.1/5, STOMP, OpenWire, and JMS. It provide…
761064active
janko/down
Down is a Ruby library for streaming, flexible, and safe downloading of remote files, with pluggable backends (Net::HTTP, http.rb, HTTPX). …
651064stable
librdkafka
Confluent's Golang client for Apache Kafka, providing high-level Producer and Consumer APIs with support for balanced consumer groups. It i…
951063stable
airbnb/chronon
Chronon is an open-source data platform from Airbnb for computing, backfilling, and serving ML features. It handles batch and streaming fea…
731063active
alibaba/Alink
Alink is a machine learning algorithm platform built on Apache Flink, developed by Alibaba's PAI team. It provides a large library of batch…
233612maintenance
jacktrip/jacktrip
JackTrip is a multi-machine audio system for network music performance over the Internet, streaming bidirectional, high-quality uncompresse…
911056active
Emiyaaaaa/HiveMind
AgentFlow (repo HiveMind) is a Python-first runtime layer for multi-agent systems that adds persistent run state, ordered step/message/tool…
631056active
clj-commons/manifold
Manifold is a Clojure library providing building blocks for asynchronous programming: deferreds for single async values and streams for ord…
611054active
libstreaming
libstreaming is an Android library that streams camera and microphone content using RTP over UDP, with H.264, H.263, AAC, and AMR encoding …
323581maintenance
abizovnuralem/go2_ros2_sdk
An unofficial ROS2 SDK for the Unitree Go2 quadruped robot (AIR/PRO/EDU), connecting over WebRTC (Wi-Fi) or CycloneDDS (Ethernet). It provi…
541048active
videoflow/videoflow
Videoflow is a Python framework for building distributed video and stream processing pipelines as directed acyclic graphs of producers, pro…
961041active
shayonj/pg_easy_replicate
pg_easy_replicate is a Ruby CLI tool that orchestrates logical replication between two PostgreSQL databases and performs switchover with mi…
731038active
Supprise0901/TVBox_live
A Python tool that searches, deduplicates, and speed-tests IPTV live stream sources, publishing curated subscription lists for TVBox-style …
721038active
twitter/scalding
Scalding is a Scala library for specifying Hadoop MapReduce jobs, built on top of the Cascading framework. It provides a type-safe, functio…
233524maintenance
CyberPunkMetalHead/Binance-volatility-trading-bot
A Python trading bot for Binance that monitors price volatility across all USDT coin pairs and automatically buys the most volatile coins, …
323493maintenance
cloudamqp/lavinmq
LavinMQ is a high-performance message queue and streaming server implementing the AMQP 0-9-1 and MQTT protocols, written in Crystal. It is …
991027active
cujojs/most
Most.js is a JavaScript toolkit for reactive programming built around monadic event streams, letting you compose asynchronous operations on…
233484maintenance
pingostack/pingos
PingOS is an NGINX-based streaming media server supporting RTMP, HTTP-FLV, HTTP-TS, HLS, HLS+, and DASH live streaming protocols with H.264…
231013active
caolan/highland
Highland is a high-level streams library for Node.js and the browser that unifies synchronous and asynchronous data sources behind a single…
323421maintenance
RaftLib/RaftLib
RaftLib is an open-source C++ library for building parallel and concurrent data processing pipelines using a stream/dataflow programming mo…
23999active
databricks/koalas
Koalas implements the pandas DataFrame API on top of Apache Spark, letting data scientists use familiar pandas code on distributed big data…
233372maintenance
brutella/hkcam
hkcam is an open-source implementation of a HomeKit IP camera that turns a Raspberry Pi or Mac with a camera into an Apple HomeKit-compatib…
23996active
jacksonliam/mjpg-streamer
A lightweight command-line streaming tool that copies JPEG frames from input plugins (webcams, Raspberry Pi camera, files, OpenCV) to outpu…
323254maintenance
chrislusf/glow
Glow is a pure-Go distributed computation library providing MapReduce-style flow APIs (Map, Filter, Reduce) that can run in parallel on a s…
323216maintenance
ReactiveX/RxCpp
RxCpp is a header-only C++ library implementing Reactive Extensions, providing algorithms for composing asynchronous and event-based stream…
233211maintenance
Kurento/kurento-media-server
Kurento Media Server is a C++/GStreamer-based media server that handles media transmission, processing, recording, and streaming over WebRT…
103053maintenance
ErsatzTV
ErsatzTV (legacy) is an open-source, self-hosted IPTV server that turns a personal media library into custom live TV channels with EPG and …
1003011maintenance
scottlawsonbc/audio-reactive-led-strip
A real-time music visualizer that drives WS2812B LED strips using Python for audio capture and FFT-based signal processing, with an ESP8266…
562987maintenance
airbnb/streamalert
StreamAlert is a serverless, real-time data analysis framework from Airbnb for ingesting, analyzing, and alerting on log data from any envi…
232891maintenance
baidu/bfs
Baidu File System (BFS) is a distributed file system written in C++ designed for real-time applications, offering fault tolerance, low read…
232847maintenance
qunarcorp/qmq
QMQ is a distributed message queue middleware developed and battle-tested at Qunar since 2012, supporting async, delayed/scheduled, broadca…
232821maintenance
hpcloud/tail
A Go library that emulates the BSD `tail -f` behavior, streaming lines from files that are continuously updated. It supports truncation and…
322779maintenance
pipelinedb/pipelinedb
PipelineDB is a PostgreSQL extension for high-performance time-series aggregation, letting you define continuous SQL queries that increment…
232664maintenance
douban/dpark
DPark is a Python clone of Apache Spark, providing a MapReduce-like distributed computing framework that supports iterative computation. Jo…
102662maintenance
SOHU-Co/kafka-node
kafka-node is a Node.js client library for Apache Kafka 0.9 through 0.11, providing producers, consumers, consumer groups, stream-based API…
232650maintenance
iotsound/iotsound
IoTSound (formerly balenaSound) is a deployable application that turns a Raspberry Pi into an audio streamer for existing speakers, support…
422625maintenance
Yelp/mrjob
mrjob is a Python library for writing and running Hadoop Streaming MapReduce jobs, with support for Amazon EMR, Google Cloud Dataproc, self…
622613maintenance
apache/logging-flume
Apache Flume is a distributed, reliable, and available service for efficiently collecting, aggregating, and moving large amounts of log-lik…
762570maintenance
nats-io/nats-streaming-server
NATS Streaming Server (STAN) is a lightweight, high-performance reliable streaming platform built on top of the NATS messaging system, prov…
102523maintenance
Project Flogo
Project Flogo is an ultra-light, Go-based open source ecosystem for building event-driven applications using triggers and actions. It suppo…
232489maintenance
tumtumtum/StreamingKit
StreamingKit is an Objective-C audio playback and streaming library for iOS and macOS built on CoreAudio, with a clean object-oriented API …
322450maintenance

← prev page 4 / 8 next →