function: streaming
706 products, primary matches first, then adoption-weighted; health v2 shown.
| Product | Health v2 | Stars | Maturity |
|---|---|---|---|
| X Recommendation Algorithm The open-source source code for X's (formerly Twitter) recommendation algorithm, a set of services and jobs that serve personalized feeds o… | 48 | 73868 | active |
| FFmpeg/FFmpeg FFmpeg is the leading open-source multimedia framework, providing libraries (libavcodec, libavformat, libavfilter, etc.) and command-line t… | 77 | 63669 | stable |
| Pathway Pathway is a Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG applications. It provides a unified Py… | 97 | 62383 | active |
| Jellyfin Jellyfin is a free, open-source media system for managing and streaming personal media collections from a dedicated server to end-user devi… | 95 | 56232 | active |
| ReactiveX/RxJava RxJava is a JVM implementation of Reactive Extensions, a library for composing asynchronous and event-based programs using observable seque… | 98 | 48204 | active |
| apache/spark Apache Spark is a unified analytics engine for large-scale data processing, providing high-level APIs in Scala, Java, Python, and R over an… | 77 | 43882 | stable |
| LizardByte/Sunshine Sunshine is a self-hosted game stream host that works with Moonlight clients, providing low-latency cloud gaming server capabilities. It su… | 90 | 40571 | active |
| apache/kafka Apache Kafka is an open-source distributed event streaming platform for building high-performance data pipelines, streaming analytics, and … | 77 | 33632 | stable |
| ReactiveX/rxjs RxJS is a reactive programming library for composing asynchronous and event-based programs using Observables. This repository hosts the nex… | 84 | 31701 | active |
| WebTorrent WebTorrent is a streaming BitTorrent client written entirely in JavaScript that runs in Node.js (using TCP/UDP) and in the browser (using W… | 98 | 31372 | active |
| alibaba/canal Canal is an Alibaba open-source component that parses MySQL binlog to provide incremental data subscription and consumption. It masquerades… | 66 | 29725 | stable |
| ossrs/srs SRS (Simple Realtime Server) is a high-performance, open-source real-time media server written in C++ that supports RTMP, WebRTC, HLS, HTTP… | 98 | 29169 | stable |
| nautechsystems/nautilus_trader NautilusTrader is an open-source, production-grade algorithmic trading platform with a Rust-native core and Python API, built on a determin… | 98 | 27886 | stable |
| apache/flink Apache Flink is an open-source distributed stream processing framework for stateful computations over unbounded and bounded data streams, w… | 77 | 26294 | stable |
| NSQ NSQ is a realtime distributed messaging platform written in Go, designed to operate at scale handling billions of messages per day. It prov… | 66 | 25775 | stable |
| taosdata/TDengine TDengine is an open-source, cloud-native time-series database (TSDB) written in C, purpose-built for IoT, connected vehicles, industrial Io… | 93 | 25090 | active |
| navidrome/navidrome Navidrome is a self-hosted, open-source web-based music collection server and streamer written in Go. It indexes your local music files and… | 97 | 23131 | active |
| apache/rocketmq Apache RocketMQ is a distributed cloud-native messaging and streaming platform built for low-latency, high-throughput, financially reliable… | 90 | 22570 | stable |
| vectordotdev/vector Vector is a high-performance observability data pipeline written in Rust that collects, transforms, and routes logs, metrics, and traces to… | 95 | 22460 | active |
| m1k1o/neko Neko is a self-hosted virtual browser that runs in Docker and streams a fully functional browser desktop to multiple users over WebRTC with… | 90 | 22193 | active |
| NATS NATS Server is a high-performance, lightweight open-source messaging system written in Go that provides pub/sub, request/reply, and durable… | 98 | 20603 | stable |
| bluenviron/mediamtx MediaMTX is a zero-dependency live media server and proxy written in Go that routes real-time video and audio streams across protocols incl… | 99 | 19938 | stable |
| open-ani/animeko Animeko is a one-stop, open-source anime discovery, tracking, and watching application built entirely in Kotlin with Compose Multiplatform.… | 98 | 19781 | active |
| ZLMediaKit/ZLMediaKit ZLMediaKit is a high-performance, enterprise-grade streaming media server framework written in C++11, supporting RTSP, RTMP, HLS, HTTP-FLV,… | 77 | 17458 | stable |
| video-dev/hls.js HLS.js is a JavaScript/TypeScript library that implements an HTTP Live Streaming (HLS) client for browsers, relying on HTML5 video and Medi… | 99 | 16899 | stable |
| Pion WebRTC Pion WebRTC is a pure Go implementation of the WebRTC API, enabling real-time audio, video, and data communication without cgo or external … | 98 | 16742 | active |
| emqx/emqx EMQX is a highly scalable MQTT broker and messaging platform written in Erlang, supporting MQTT 5.0/3.1.1/3.1 plus MQTT-SN, CoAP, LwM2M, an… | 99 | 16659 | stable |
| apache/hadoop Apache Hadoop is an open-source framework for reliable, scalable distributed storage (HDFS) and processing (MapReduce, YARN) of large data … | 77 | 15640 | stable |
| apache/pulsar Apache Pulsar is a cloud-native, distributed pub-sub messaging and streaming platform originally developed at Yahoo and now a top-level Apa… | 98 | 15315 | stable |
| elastic/logstash Logstash is an open-source server-side data processing pipeline that ingests data from multiple sources simultaneously, transforms it, and … | 95 | 14925 | stable |
| benbjohnson/litestream Litestream is a standalone disaster recovery tool for SQLite that runs as a background process and continuously streams database changes to… | 98 | 14306 | active |
| Audiobookshelf Audiobookshelf is an open-source, self-hosted media server for streaming and managing audiobooks and podcasts, with companion Android and i… | 97 | 14135 | active |
| AlexxIT/go2rtc go2rtc is a zero-dependency camera streaming application and media server written in Go that supports dozens of streaming formats and proto… | 84 | 14050 | active |
| apache/druid Apache Druid is a high-performance, distributed, real-time analytics database written in Java for fast OLAP-style slice-and-dice queries on… | 89 | 14045 | stable |
| arut/nginx-rtmp-module An NGINX module that turns the nginx web server into a media streaming server supporting RTMP, HLS, and MPEG-DASH. It handles live streamin… | 32 | 14035 | stable |
| RabbitMQ RabbitMQ is an open source, multi-protocol messaging and streaming broker supporting AMQP 0-9-1, AMQP 1.0, MQTT, STOMP, and its Streams pro… | 99 | 13807 | stable |
| Fluentd Fluentd is an open-source data collector that unifies log and event collection from many sources and routes them to files, databases, cloud… | 92 | 13579 | stable |
| Debezium Debezium is an open source distributed platform for change data capture (CDC) that streams row-level database changes as events, most commo… | 77 | 13049 | stable |
| redpanda-data/redpanda Redpanda is a Kafka API-compatible streaming data platform written in C++ on the Seastar framework, with no ZooKeeper or JVM dependency. It… | 94 | 12486 | stable |
| daniulive/SmarterStreaming SmarterStreaming (大牛直播SDK/SmartMediaKit) is a proprietary cross-platform low-latency streaming SDK for Windows, Linux, Android, iOS, Harmon… | 67 | 11171 | active |
| perspective-dev/perspective Perspective is an interactive analytics and data visualization component for large, real-time, and streaming datasets, built around a high-… | 99 | 11133 | active |
| dotnet/orleans Microsoft Orleans is a cross-platform .NET framework for building robust, scalable distributed applications using the Virtual Actor Model. … | 97 | 10844 | stable |
| ClassicOldSong/Apollo Apollo is a self-hosted game-streaming host (a fork of Sunshine) that streams a desktop to Moonlight/Artemis clients at the client's native… | 62 | 10682 | active |
| AutoMQ/automq AutoMQ is a cloud-native, 100% Apache Kafka-compatible streaming platform that replaces broker-local disks with S3-compatible object storag… | 95 | 10574 | active |
| electric-sql/electric Electric is a real-time read-path sync engine for Postgres that replicates data into clients via a low-level HTTP API with partial replicat… | 95 | 10339 | active |
| gwuhaolin/livego Livego is a simple, high-performance live video streaming server written in pure Go. It accepts RTMP pushes and serves playback over RTMP, … | 48 | 10185 | active |
| KoljaB/RealtimeSTT RealtimeSTT is a Python library for low-latency, real-time speech-to-text with voice activity detection, wake word activation, and streamin… | 94 | 10080 | active |
| ThreeDotsLabs/watermill Watermill is a Go library for building event-driven and message-driven applications over a unified Pub/Sub API. It supports Kafka, RabbitMQ… | 95 | 9864 | active |
| apache/seatunnel Apache SeaTunnel is a distributed, high-performance data integration platform for synchronizing massive amounts of data across hundreds of … | 82 | 9587 | stable |
| risingwavelabs/risingwave RisingWave is an event streaming platform that continuously ingests data from databases, event streams, and webhooks, processes it incremen… | 99 | 9290 | active |
| Delta Lake Delta Lake is an open-source storage framework and table format that brings ACID transactions, scalable metadata handling, schema enforceme… | 95 | 8960 | stable |
| HerbertHe/iptv-sources A service that automatically aggregates and updates IPTV m3u playlist sources from multiple public repositories, with EPG data and optional… | 71 | 8921 | active |
| aeron-io/aeron Aeron is an efficient, reliable message transport supporting UDP unicast, UDP multicast, and IPC, with Java, C, and C++ clients. It include… | 99 | 8818 | stable |
| redpanda-data/connect Redpanda Connect (formerly Benthos) is a declarative stream processor that moves data between hundreds of sources and sinks with transforma… | 95 | 8736 | active |
| apache/beam Apache Beam is an open-source unified programming model and SDK set (Java, Python, Go, SQL, TypeScript) for defining batch and streaming da… | 93 | 8650 | stable |
| segmentio/kafka-go kafka-go is a pure-Go Apache Kafka client library offering both low-level connection APIs and high-level Reader/Writer abstractions for pro… | 75 | 8613 | active |
| snapcast/snapcast Snapcast is a multiroom client-server audio player that synchronizes playback across networked clients with sub-millisecond timing accuracy… | 86 | 7842 | active |
| gaotianliuyun/gao A curated collection of configuration files for TVBox, FongMi TV (FongMi影视), and CatVod (猫影视) Android TV streaming apps. The JSON configs a… | 32 | 7769 | active |
| mediasoup mediasoup is a powerful WebRTC SFU (Selective Forwarding Unit) implemented as a Node.js module and Rust crate, with a C++ media worker subp… | 95 | 7345 | stable |
| 648540858/wvp-GB28181-pro An open-source network video platform implementing China's GB28181-2016 and JT808/JT1078 standards, providing SIP signaling, device managem… | 76 | 7267 | active |
| dotnet/reactive The Reactive Extensions for .NET (Rx.NET) is a family of libraries providing composable, declarative event-driven programming via observabl… | 94 | 7189 | active |
| snowplow/snowplow Snowplow is a Customer Data Infrastructure platform that collects, validates, enriches, and streams event-level behavioral data from web, m… | 63 | 7029 | stable |
| EasyDarwin/EasyDarwin EasyDarwin is an open-source, high-performance streaming media server supporting RTSP/RTMP push and pull streams with distribution over RTM… | 57 | 6834 | active |
| Hazelcast Hazelcast is a unified real-time data platform combining distributed stream processing with a fast, in-memory data store. It lets applicati… | 82 | 6604 | stable |
| AlkaidLab/foundation-sunshine An enhanced fork of LizardByte/Sunshine, a self-hosted game streaming host that serves Moonlight clients. It adds full HDR10/HDR Vivid/HLG … | 98 | 6601 | active |
| apache/flink-cdc Flink CDC is a distributed streaming data integration tool built on Apache Flink that captures change data from databases like MySQL and Po… | 83 | 6468 | active |
| apache/iotdb Apache IoTDB is an open-source time-series database management system designed for industrial IoT, providing integrated collection, storage… | 92 | 6382 | stable |
| MaterializeInc/materialize Materialize is a streaming database that uses incremental computation to maintain always-fresh, strongly consistent SQL views over data fro… | 99 | 6361 | active |
| WonderTrader WonderTrader is a high-performance C++-core quantitative trading framework covering the full lifecycle from data ingestion and backtesting … | 52 | 6297 | active |
| illuspas/Node-Media-Server Node-Media-Server is a high-performance, low-latency live streaming media server implemented in Node.js, supporting RTMP/RTMPS and HTTP/WS-… | 67 | 6240 | active |
| apache/hudi Apache Hudi is an open data lakehouse platform built on a high-performance open table format that brings database functionality like transa… | 91 | 6219 | stable |
| apache/nifi Apache NiFi is an easy-to-use, powerful, and reliable system to process and distribute data, built on the JVM. It provides a browser-based … | 94 | 6208 | stable |
| anacrolix/torrent A full-featured BitTorrent client library and CLI utilities written in Go, designed to be embedded in other projects. It supports streaming… | 77 | 6100 | stable |
| online-ml/river River is a Python library for online machine learning, allowing models to learn incrementally from streaming data one observation at a time… | 94 | 5924 | active |
| dpkp/kafka-python kafka-python is a pure-Python client library for Apache Kafka with no external dependencies, providing high-level consumer, producer, and a… | 99 | 5898 | active |
| koush/scrypted Scrypted is a high-performance, self-hosted video integration and automation platform that ingests streams from most IP cameras and relays … | 83 | 5874 | active |
| kurrent-io/KurrentDB KurrentDB (formerly EventStoreDB) is an event-native database designed for event-driven architectures, storing data as immutable event stre… | 99 | 5848 | active |
| rethinkdb/rethinkdb RethinkDB is an open-source, distributed NoSQL database that stores schemaless JSON documents and pushes updated query results to applicati… | 56 | 26994 | maintenance |
| dlt-hub/dlt dlt (data load tool) is an open-source Python library for building ELT data pipelines that extract data from REST APIs, SQL databases, clou… | 98 | 5778 | stable |
| fluvio-community/fluvio Fluvio is a distributed data streaming engine written in Rust that combines a Kafka-like event streaming platform with the Stateful DataFlo… | 79 | 5247 | active |
| reactor/reactor-core Reactor Core is a non-blocking reactive streams foundation library for the JVM, implementing a Reactive Extensions-inspired API with the Fl… | 99 | 5234 | stable |
| bilibili/flv.js A pure-JavaScript HTML5 FLV player that transmuxes FLV streams into fragmented MP4 segments and plays them via Media Source Extensions. It … | 23 | 23194 | maintenance |
| ReactiveX/RxGo RxGo is the official ReactiveX implementation for Go, providing composable observable streams built on Go channels and goroutines. It offer… | 24 | 5098 | active |
| akkadotnet/akka.net Akka.NET is an idiomatic .NET port of the Akka toolkit implementing the actor model for building highly concurrent, distributed, and fault-… | 99 | 5080 | active |
| jitsucom/jitsu Jitsu is an open-source, self-hostable event data platform and Segment alternative that collects event data from websites, apps, and server… | 97 | 5043 | active |
| ReactiveX/RxPY ReactiveX for Python (RxPY) is a library for composing asynchronous and event-based programs using observable sequences and pipable query o… | 89 | 5018 | active |
| ArroyoSystems/arroyo Arroyo is a distributed stream processing engine written in Rust that lets users run stateful computations on high-volume real-time data st… | 78 | 5016 | active |
| sorayuki/obs-multi-rtmp An OBS Studio plugin that enables simulcasting (simultaneous live streaming) to multiple RTMP servers/sites at once. Originally created for… | 88 | 5015 | active |
| Emby Server Emby Server is a self-hosted personal media server that organizes videos, music, photos, and live TV into a rich library and streams them t… | 23 | 4961 | active |
| reactive-streams/reactive-streams-jvm The Reactive Streams specification for the JVM, defining a minimal set of interfaces (Publisher, Subscriber, Subscription, Processor) for a… | 32 | 4879 | stable |
| BililiveRecorder/BililiveRecorder BililiveRecorder (录播姬) is a free, open-source tool for recording Bilibili (mikufans) live streams, available as a Windows desktop app with … | 85 | 4798 | active |
| apache/rocketmq-externals The Apache RocketMQ externals repository is the community home for incubating ecosystem projects around the RocketMQ message broker, such a… | 71 | 4601 | active |
| apache/iggy Apache Iggy is a high-performance, persistent message streaming platform written in Rust, supporting TCP, QUIC, HTTP, and WebSocket transpo… | 86 | 4545 | active |
| hotheadhacker/seedbox-lite SeedBox Lite is a self-hosted torrent streaming media center that lets users watch movies and TV shows instantly while torrents download. I… | 34 | 4536 | active |
| DistroAV/DistroAV DistroAV (formerly OBS-NDI) is a plugin for OBS Studio that adds NDI (Network Device Interface) integration for sending and receiving audio… | 84 | 4515 | active |
| rudderlabs/rudder-server RudderStack's open-source event streaming server, a privacy- and security-focused Segment alternative written in Go. It collects customer e… | 95 | 4477 | active |
| mortdeus/solana-copy-sniper-mev-trading-bot A high-speed Solana trading bot combining copy trading, token sniping, MEV arbitrage, and sandwich strategies, built with Rust and Node.js.… | 51 | 4440 | active |
| zio/zio ZIO is a zero-dependency Scala library for type-safe, composable asynchronous and concurrent programming, built on lightweight fibers. It p… | 89 | 4410 | stable |
| restatedev/restate Restate is a lightweight distributed runtime that turns backend services, workflows, and AI agents into durable processes with automatic re… | 98 | 4343 | active |
| albfan/miraclecast MiracleCast is a C implementation of the Wi-Fi Display (Miracast) specification for Linux, providing both Display-Sink and (planned) Displa… | 64 | 4331 | active |
page 1 / 8 next →