apache / streampipes
Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams.
apache / streampipes
youngmonkeys / ezyfox-server
A socket server (include SSL) supports realtime application, realtime game, MMORPG, messaging, chat and streaming data with TCP, UDP and Websocket
pivovarit / parallel-collectors
Parallel Collectors is a toolkit easing parallel collection processing in Java using Stream API.
akarnokd / RxJavaExtensions
RxJava 4.x extra sources, operators and components and ports of many 1.x companion libraries.
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
jitsi / libjitsi
Advanced Java media library for secure real-time audio/video communication.
scalecube / scalecube-services
Microservices library - scalecube-services is a high throughput, low latency reactive microservices library built to scale. It features: API-Gateways, service-discovery, service-load-balancing, the architecture supports plug-and-play service communication modules and features. built to provide performance and low-latency real-time stream-processing
eclipse-kura / kura
Eclipse Kura™ is a versatile framework to supercharge your edge devices, streamlining the process of configuring your gateway, connecting sensors, and IoT devices to seamlessly collect, process, and send data to the cloud.
ExtractPDF4J / ExtractPDF4J
Java PDF table extraction & OCR library. Extract structured tables from text-based and scanned PDFs using stream, lattice (OpenCV-style grid detection), and hybrid parsing.
zj-unicom-ai / vision-hub-platform
Build visual detection tasks fast with an open-source platform. Connect cameras, video streams, and heterogeneous vision models; define algorithms with prompts; configure frame sampling and detection regions; and manage alerts. Everything you need to put visual AI to work, in one place.
xantipater / GTV2STREAM
—
hypnguyen1209 / log4j2-rce
Pre-auth RCE via FilteredObjectInputStream MarshalledObject bypass in Apache Log4j 2
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.
git-syl / hermes-agent-demo
A multi-model Agent runtime built on Spring Boot 4 / Spring AI 2.0: model routing (Anthropic / DeepSeek / OpenAI / custom), thinking toggle, Task subagents, hot-pluggable Skills, Docker sandbox + Code Interpreter, MCP tools, dify/n8n integration, RAG with pgvector, Human-in-the-Loop approvals — all streamed as structured SSE events.
dinosn / log4j-4255
End-to-end Docker lab reproducing Apache log4j2 #4255 — FilteredObjectInputStream allowlist bypass via java.rmi.MarshalledObject (unfiltered deserialization → RCE) on Log4j 2.26.1 / JDK 17.
openlakestream / ursa
Ursa: a storage engine that implements Lakestream, an open API and specification for stream storage on object storage.
authorjapps / zerocode
zerocode-tdd is a community-developed, free, open-source, outcome-driven automated testing framework for Data Pipelines, ETL, REST API, Kafka(Data Streams), Databases and Load scenarios. all defined in simple JSON or YAML — with zero coding.
google / mug
A small Java 8 library (string manipulation, BiStream, Structured Concurrency, SQL Templates)
kiegroup / optaplanner
Midstream of https://github.com/apache/incubator-kie-optaplanner