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

function: streaming

706 products, primary matches first, then adoption-weighted; health v2 shown.

ProductHealth v2StarsMaturity
alibaba/otter
Otter is Alibaba's distributed database synchronization system that parses database incremental logs (via Canal) to replicate data near-rea…
238126maintenance
WWBN/AVideo
AVideo is an open-source PHP-based video streaming platform for hosting your own video sharing site with VOD and live streaming support. It…
922100active
yuanzl77/IPTV
A Python tool that aggregates IPTV live streaming sources daily, validates them with HTTP checks and FFprobe quality probing, and generates…
692100active
themactep/thingino-firmware
Thingino is an open-source firmware for IP cameras built on Ingenic SoCs, replacing locked-down vendor software with a transparent, communi…
982091active
jeffshee/hidamari
Hidamari is a video wallpaper application for Linux written in Python that lets users set videos, streaming URLs, or webpages as their desk…
822091active
mkckr0/audio-share
Audio Share streams a Windows or Linux computer's audio over the network to an Android phone, turning the phone into a wireless speaker for…
442091active
antimof/UxPlay
UxPlay is an open-source AirPlay Mirror and AirPlay Audio server for Linux, macOS, Unix, and Windows, written in C. It lets Apple devices s…
662084active
ledgetech/lua-resty-http
A Lua HTTP client cosocket driver for OpenResty / ngx_lua, supporting HTTP 1.0/1.1, SSL, streaming response bodies, keepalives, and request…
852078stable
feldera/feldera
Feldera is an incremental computation engine written in Rust that evaluates arbitrary SQL programs incrementally using DBSP theory, maintai…
922064active
mpromonet/v4l2rtspserver
A C++ RTSP streaming server that captures video from V4L2 devices (H264, HEVC, JPEG, VP8, VP9) and optionally audio from ALSA devices, serv…
852049active
wbt5/real-url
A Python collection of scripts that extracts real streaming URLs (live stream sources) and danmaku (bullet comments) from 59 Chinese and in…
327827maintenance
stackia/rtp2httpd
A lightweight IPTV streaming relay server written in C that converts multicast RTP/UDP, RTSP, and HLS sources into unicast HTTP streams. It…
902013active
exelix11/SysDVR
SysDVR is a Nintendo Switch homebrew sysmodule that captures running game output and streams it to a PC over USB or network (RTSP). It prov…
812011active
pravega/pravega
Pravega is an open-source distributed storage service that implements Streams as a first-class primitive: durable, elastic, append-only, un…
271997active
fede1024/rust-rdkafka
rust-rdkafka is a fully asynchronous, futures-based Apache Kafka client library for Rust built on top of the librdkafka C library. It provi…
741996stable
JurajNyiri/HomeAssistant-Tapo-Control
A Home Assistant custom component (HACS-installable) that integrates TP-Link Tapo cameras, doorbells, and chimes, providing control, PTZ, m…
921985active
ssili126/tv
A Python tool that automatically collects IPv4 hotel IPTV live stream sources (including CCTV, satellite, and some local Chinese channels),…
701956active
apache/cassandra-spark-connector
The official Apache Spark connector for Apache Cassandra, letting Spark applications read Cassandra tables as RDDs and DataFrames, write th…
311954active
rvagg/through2
A tiny Node.js library that wraps stream Transform logic in simple functions, avoiding explicit subclassing of stream.Transform. It support…
981907stable
EverythingSuckz/TG-FileStreamBot
A Telegram bot written in Go that generates instant direct HTTP streaming links for Telegram files without waiting for downloads to complet…
661895active
faust-streaming/faust
Faust-streaming is a Python stream processing library that ports Kafka Streams ideas to Python using asyncio, letting developers build dist…
991884active
keshavdv/unifi-cam-proxy
A Python proxy that lets non-Ubiquiti RTSP-enabled cameras appear as native cameras in UniFi Protect NVR. It supports live streaming, full-…
771869active
asavinov/intelligent-trading-bot
A Python-based automated cryptocurrency trading bot that generates trade signals using machine learning and feature engineering. It separat…
761860active
zhp8341/flink-streaming-platform-web
A lightweight web-based management platform built on Apache Flink that lets users configure, deploy, and monitor streaming compute jobs ent…
481858active
pinterest/secor
Secor is a Java service that persists Apache Kafka log messages to object stores such as Amazon S3, Google Cloud Storage, Azure Blob Storag…
641856stable
destel/rill
Rill is a Go library providing composable, channel-based concurrency primitives built on generics. It lets developers build concurrent pipe…
781852active
nisshi-io/nisshi
Nisshi is a stateless, Kafka API-compatible message broker written in async Rust with pluggable storage engines (PostgreSQL, SQLite/libSQL,…
881851active
alibaba/MongoShake
MongoShake is a Go-based universal data replication platform built on MongoDB's oplog, fetching changes from a source MongoDB and replaying…
821820active
protonemedia/laravel-ffmpeg
A Laravel package that wraps PHP-FFMpeg to provide an elegant, testable API for video and audio processing, with deep integration into Lara…
721814active
Angel-ML/angel
Angel is a high-performance distributed parameter server for large-scale machine learning and graph computing, developed by Tencent and Pek…
696787maintenance
robustmq/robustmq
RobustMQ is a next-generation message queue infrastructure written in Rust that supports multiple protocols (MQTT, Kafka, AMQP) with a sing…
931787active
apache/storm
Apache Storm is a free and open-source distributed realtime computation system for processing unbounded streams of data, providing primitiv…
976698maintenance
LMS-Community/slimserver
Lyrion Music Server (LMS, formerly Logitech Media Server/SlimServer) is an open-source streaming audio server written in Perl that powers S…
771763active
vexorian/dizquetv
dizqueTV is a self-hosted web application that creates simulated live TV channels from media on your Plex servers. It exposes channels via …
661760active
lf-edge/ekuiper
LF Edge eKuiper is a lightweight stream processing engine for IoT edge devices, offering SQL-based and graph-based rule engine for real-tim…
981731active
savonet/liquidsoap
Liquidsoap is a statically typed scripting language and runtime for building audio and video stream generators, widely used for internet ra…
921720stable
numenta/nupic-legacy
NuPIC is Numenta's open-source machine intelligence platform implementing Hierarchical Temporal Memory (HTM), a computational theory of the…
236350maintenance
aculix/bitplay
BitPlay is a self-hosted Go web application that streams video content directly from torrents (magnet links or .torrent files) in the brows…
741702active
Threadfin/Threadfin
Threadfin is an M3U proxy server for Plex DVR and Emby/Jellyfin Live TV, forked from xTeVe. It merges and filters external M3U playlists an…
571696active
deepch/RTSPtoWeb
RTSPtoWeb is a self-hosted Go server that converts RTSP camera streams into browser-playable formats such as MSE, WebRTC, and HLS, without …
671692active
durable-streams/durable-streams
Durable Streams is a protocol and tooling for persistent, addressable, real-time data streams over HTTP, with offset-based resumability, ca…
741674active
trustmaster/goflow
GoFlow is a lean Flow-based Programming (FBP) library for Go that lets developers build applications as graphs of concurrent components con…
891671active
FrigadeHQ/trench
Trench is an open-source event tracking and analytics infrastructure built on Apache Kafka and ClickHouse, shipped as a single production-r…
581661active
c9s/bbgo
BBGO is an open-source cryptocurrency trading bot framework written in Go, supporting multiple exchanges like Binance and MAX through a com…
881657active
unitreerobotics/xr_teleoperate
xr_teleoperate is a Python application from Unitree Robotics that enables teleoperation of Unitree humanoid robots (G1, H1_2, H2, R1) using…
661633active
apache/pekko
Apache Pekko is an open-source JVM framework for building concurrent, distributed, and resilient message-driven applications using the Acto…
771629active
XITRIX/Moonlight-Switch
A port of the Moonlight game streaming client to the Nintendo Switch homebrew platform, also available for iOS, tvOS, and macOS. It streams…
881614active
WiVRn/WiVRn
WiVRn is a fully open-source OpenXR application that wirelessly streams VR games from a Linux PC to standalone Android-based VR headsets li…
971613active
nerevu/riko
riko is a pure Python stream processing library modeled after Yahoo! Pipes, combining reusable, configuration-driven modular pipes with syn…
881606active
shane-mason/FieldStation42
FieldStation42 is a broadcast and cable TV simulator that turns a Linux computer or Raspberry Pi into a retro television experience with sc…
681599active
apache/gluten
Apache Gluten is a middle-layer plugin that offloads JVM-based SQL engine execution (primarily Spark SQL) to high-performance native engine…
911592active
elixir-lang/gen_stage
GenStage is an Elixir specification and behaviour for exchanging events between producer and consumer stages with built-in back-pressure. I…
751590stable
getdozer/dozer
Dozer is a real-time data movement tool written in Rust that captures change data (CDC) from sources like Postgres, MySQL, Snowflake, and K…
231579active
callbag/callbag
Callbag is a lightweight specification/standard for JavaScript callbacks that enables minimal-overhead observables, iterables, and async it…
321575stable
quixio/quix-streams
Quix Streams is a pure Python framework for building real-time data pipelines and event-driven applications on Apache Kafka using a Streami…
971568active
renmu123/biliLive-tools
An all-in-one desktop application for live stream recording and post-processing, supporting multi-platform recording (Bilibili, Douyu, Huya…
901555active
mosaicml/streaming
StreamingDataset is a Python library from MosaicML for fast, accurate streaming of training data from cloud object storage (S3, GCS, Azure,…
701547active
nats-io/nats.rs
async-nats is a Rust client library for the NATS cloud-native messaging system, built on Tokio. It supports Core NATS, JetStream, Key-Value…
901536active
chatop2020/AKStream
AKStream is a cross-platform, software-defined NVR (network video recorder) management and control platform written in C# on .NET 6, integr…
761529active
stegripe/rawon
Rawon is a self-hostable Discord music bot built with discord.js and TypeScript that plays music from YouTube Music, Spotify, SoundCloud, a…
991523active
pyper-dev/pyper
Pyper is a pure-Python library for building concurrent and parallel data pipelines using functional programming patterns. It unifies thread…
281518active
membraneframework/membrane_core
Membrane Core is the heart of Membrane Framework, a multimedia processing and streaming framework written in Elixir. It lets developers bui…
951508active
eulerto/wal2json
wal2json is a PostgreSQL logical decoding output plugin written in C that converts write-ahead log changes (INSERT, UPDATE, DELETE) into JS…
671508stable
mafintosh/csv-parser
A fast streaming CSV parser for Node.js that converts CSV into JSON objects, compatible with the csv-spectrum acid test suite. It can also …
591502stable
apache/inlong
Apache InLong is a one-stop, full-scenario integration framework for massive data, supporting data ingestion, synchronization, and subscrip…
901497stable
locationtech/geomesa
GeoMesa is an open-source suite of JVM-based tools for large-scale geospatial querying and analytics on distributed computing systems. It p…
781494active
teamclouday/AndroidMic
AndroidMic is a cross-platform app that turns an Android phone into a microphone for a PC, streaming audio over WiFi (TCP/UDP), USB Serial,…
911488active
technomancer702/nodecast-tv
nodecast-tv is a self-hosted web-based IPTV player that streams Live TV, Movies, and Series from Xtream Codes or M3U providers directly in …
581480active
moq-dev/moq
An open-source implementation of Media over QUIC (MoQ), a next-generation live media protocol delivering WebRTC-like real-time latency at m…
951477active
Netflix/mantis
Mantis is a Netflix open-source stream processing platform written in Java for building realtime, cost-effective, operations-focused applic…
671470active
filodb/FiloDB
FiloDB is a distributed, in-memory, Prometheus-compatible time series database written in Scala, designed for real-time ingestion of metric…
671467active
mit-pdos/noria
Noria is a streaming data-flow storage backend written in Rust that acts like a database but precomputes and incrementally maintains materi…
325244maintenance
apache/hop
Apache Hop is an open-source data and metadata orchestration platform for visually designing and running data integration pipelines and wor…
941447active
datazip-inc/olake
OLake Go is a high-performance open-source EL (extract-load) engine written in Go that replicates databases (PostgreSQL, MySQL, MongoDB, Or…
841431active
ReactiveX/IxJS
IxJS is a TypeScript library that brings Array#extras-style combinators like map, filter, and reduce to synchronous and asynchronous iterab…
321411active
midarrlabs/midarr-server
Midarr is a free, open-source, lightweight media server that serves your existing media library through a slick web interface. It acts as a…
541407active
superstreamerapp/superstreamer
Superstreamer is a self-hostable, scalable video streaming platform that covers the full pipeline from transcoding and HLS packaging to dyn…
511407active
airsonic-advanced/airsonic-advanced
Airsonic-Advanced is a free, web-based media streamer for personal music collections, a modernized fork of Airsonic with improved security,…
231405active
aio-libs/aiokafka
aiokafka is an asyncio-based Python client library for Apache Kafka, providing AIOKafkaProducer and AIOKafkaConsumer high-level classes. It…
801399active
Arthi-chaud/Meelo
Meelo is a self-hosted music streaming server designed for music collectors, similar to Plex or Jellyfin but focused on music. It offers ri…
991398active
emqx/neuron
Neuron is an open-source industrial IoT connectivity server written in C that bridges factory-floor devices (PLCs, sensors, meters) with mo…
951390active
gerbera/gerbera
Gerbera is a free, open-source UPnP/DLNA media server that streams digital media across a home network to compatible devices like TVs, game…
861390active
fuatakgun/eufy_security
A Home Assistant integration that connects Eufy Security devices (cameras, doorbells, home base stations, motion and contact sensors) to Ho…
871386active
aerospike/aerospike-server
Aerospike is a distributed, flash-optimized NoSQL database server written in C that combines in-memory speeds with SSD-based durability thr…
901375stable
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…
304909maintenance
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…
231333active
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…
751326stable
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…
831324active
GoogleCloudPlatform/DataflowTemplates
A collection of Google-provided Apache Beam pipeline templates for Google Cloud Dataflow that solve common in-cloud data tasks like import/…
951310active
mesamirh/MovieBox-Tui
MovieBox-TUI is a Rust terminal application (built on Ratatui) for searching, streaming, and downloading movies, TV shows, anime, and live …
801310active
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…
661310active
SkipLabs/skip
Skip is an open-source framework for building reactive backend services, featuring an incremental compute engine that automatically keeps d…
781307active
arkflow-rs/arkflow
ArkFlow is a high-performance stream processing engine written in Rust on top of Tokio, connecting configurable inputs (Kafka, MQTT, HTTP, …
701302active
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)…
621298active
hydro-project/hydro
Hydro is a Rust framework for building correct and performant distributed systems using location-oriented programming, where a single progr…
931292active
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, …
324480maintenance
Alpakka
Akka is a JVM-based platform built on the actor model for building concurrent, distributed, and resilient applications, comprising core lib…
941268active
meta-pytorch/data
TorchData is a PyTorch library providing scalable, performant data loading utilities, including StatefulDataLoader, a drop-in replacement f…
671263active
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…
811262active

← prev page 3 / 8 next →