apache / kafka
Apache Kafka - A distributed event streaming platform
apache / kafka
TeamNewPipe / NewPipe
A libre lightweight streaming front-end for Android.
apache / rocketmq
Apache RocketMQ is a cloud native messaging and streaming platform, making it simple to build event-driven applications.
apache / pulsar
Apache Pulsar - distributed pub-sub messaging system
elastic / logstash
Logstash - transport and process your logs, events, or other data
debezium / debezium
Change data capture for a variety of databases. Please log issues at https://github.com/debezium/dbz/issues.
apache / seatunnel
SeaTunnel is a multimodal, high-performance, distributed, massive data integration tool.
apache / beam
Apache Beam is a unified programming model for Batch and Streaming data processing.
Angel-ML / angel
A Flexible and Powerful Parameter Server for large-scale machine learning
apache / storm
Apache Storm
apache / flink-cdc
Flink CDC is a streaming data integration tool
obsidiandynamics / kafdrop
Kafka Web UI
strimzi / strimzi-kafka-operator
Apache Kafka® running on Kubernetes
tonikelope / megabasterd
Yet another unofficial (and ugly) cross-platform MEGA downloader/uploader/streaming suite.
ant-media / Ant-Media-Server
Ant Media Server — Ultra-low latency streaming engine with WebRTC (~0.5s), SRT, RTMP, HLS, CMAF, adaptive bitrate, transcoding & scaling
apache / streampark
The Open Control Plane for Real-Time Data
Atmosphere / atmosphere
Portable AI agent runtime for the JVM. One @Agent class runs on Spring AI, LangChain4j, Anthropic, or 9 more behind one SPI. Token streaming, tool calls, human approvals, and governance over WebSocket, SSE, gRPC, or WebTransport/HTTP3. Speaks MCP, A2A, and AG-UI.
FasterXML / jackson-databind
General data-binding package for Jackson: works on streaming API (core) implementation(s)
apache / paimon
Apache Paimon is a lake format that enables building a Realtime Lakehouse Architecture with Flink and Spark for both streaming and batch operations.
CodeRayZhang / Movie_Recommend
历史学习项目：Spark 电影推荐、爬虫、Web 与后台。新版持续开发见 cinematch-recommender。
anonfaded / FadCam
Open-source, ad-free Android multimedia recorder with background video recording, screen recording, live streaming, and remote camera control
zeromq / jeromq
JeroMQ is a pure Java implementation of the ZeroMQ messaging library, offering high-performance asynchronous messaging for distributed or concurrent applications.
FasterXML / jackson-core
Core part of Jackson that defines Streaming API as well as basic shared abstractions
apache / gobblin
A distributed data integration framework that simplifies common aspects of big data integration such as data ingestion, replication, organization and lifecycle management for both streaming and batch data ecosystems.
apache / fluss
Apache Fluss is a streaming storage built for real-time analytics.
DSheirer / sdrtrunk
A cross-platform java application for decoding, monitoring, recording and streaming trunked mobile and related radio protocols using Software Defined Radios (SDR). Website:
TeamNewPipe / NewPipeExtractor
NewPipe's core library for extracting data from streaming sites
apache / eventmesh
EventMesh is a new generation serverless event middleware for building distributed event-driven applications.
aklivity / zilla
🦎 A lightweight, multi-protocol gateway for event-driven applications and AI agents. Expose and govern Kafka, MQTT, APIs, and MCP through one high-performance engine with shared routing, security, schema, and observability.
siddhi-io / siddhi
Stream Processing and Complex Event Processing Engine
apache / hop
Hop Orchestration Platform
agents-flex / agents-flex
Agents-flex is A lightweight Java AI agent development framework (positioned as a counterpart to Spring AI). It supports features such as RAG, MCP, Skills, Text2SQL , LLM Wiki, Sub-agents, Web Search, TTS (synchronous and streaming), and STT.
apache / datasketches-java
A software library of stochastic streaming algorithms, a.k.a. sketches.
apache / geaflow
Apache GeaFlow: A Streaming Graph Computing Engine.
youngmonkeys / ezyfox-server
A socket server (include SSL) supports realtime application, realtime game, MMORPG, messaging, chat and streaming data with TCP, UDP and Websocket
Waikato / moa
MOA is an open source framework for Big Data stream mining. It includes a collection of machine learning algorithms (classification, regression, clustering, outlier detection, concept drift detection and recommender systems) and tools for evaluation.
CorfuDB / CorfuDB
A cluster consistency platform
Suz41 / Fishbowl
Standalone Jellyfin Media Server & companion automation suite for Android ARM64.
Vinist123 / zhuling
ZhuLing — Zero-config AI Agent framework for Java. One YAML to launch Agents on Spring AI + DDD, with MCP tools, full observability and a ReAct core. Ai Agent 快速开发框架
Gerato25 / Music-App-Src
Enjoy downloading your dream collection from over 50 million songs across English,Hindi,Telugu,Tamil,Punjabi and More. Remove the hurdles of streaming low-quality content and enjoy your favorite music on your favorite Music Player by downloading any required song on a single click directly into your local storage.
RamazanKara / nightjar
Nightjar: a low-latency Android client for streaming games from your PC. Works with Sunshine, Apollo, Vibepollo, Rubylight and GeForce Experience, and adapts to each host. PyroWave, FSR/GSR upscaling, DualSense over USB.
openlakestream / ursa
Ursa: a storage engine that implements Lakestream, an open API and specification for stream storage on object storage.