apache / kafka
Apache Kafka - A distributed event streaming platform
apache / kafka
ReactiveX / RxJava
RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.
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.
questdb / questdb
QuestDB is a high performance, open-source, time-series database
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.
aeron-io / aeron
Efficient reliable UDP unicast, UDP multicast, and IPC message transport
apache / beam
Apache Beam is a unified programming model for Batch and Streaming data processing.
hs-web / hsweb-framework
hsweb (haʊs wɛb) 是一个基于spring-boot 2.x开发 ,首个使用全响应式编程的企业级后台管理系统基础项目。
Angel-ML / angel
A Flexible and Powerful Parameter Server for large-scale machine learning
apache / storm
Apache Storm
jetlinks / jetlinks-community
JetLinks 基于Java,Spring Boot ,WebFlux,Netty,Vert.x,Reactor等开发, 是一个全响应式的企业级物联网平台。支持统一物模型管理,多种设备,多种厂家,统一管理。统一设备连接管理,多协议适配(TCP,MQTT,UDP,CoAP,HTTP等),屏蔽网络编程复杂性,灵活接入不同厂家不同协议等设备。实时数据处理,设备告警,消息通知,数据转发。地理位置,数据可视化等。能帮助你快速建立物联网相关业务系统。
hazelcast / hazelcast
Hazelcast is a unified real-time data platform combining stream processing with a fast data store, allowing customers to act instantly on data-in-motion for real-time insights.
apache / flink-cdc
Flink CDC is a streaming data integration tool
apache / hudi
Upserts, Deletes And Incremental Processing on Big Data.
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.
reactor / reactor-core
Non-Blocking Reactive Foundation for the JVM
line / armeria
Your go-to microservice framework for any situation, from the creator of Netty et al. You can build any type of microservice leveraging your favorite technologies, including gRPC, Thrift, Kotlin, Retrofit, Reactive Streams, Spring Boot and Dropwizard.
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
knowm / XChange
XChange is a Java library providing a streamlined API for interacting with 60+ Bitcoin and Altcoin exchanges providing a consistent interface for trading and accessing market 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.
Snailclimb / interview-guide
基于 Spring Boot 4.1、Java 25、Spring AI 2.0、React、PostgreSQL/pgvector、Redis 和 RustFS 构建的开源 AI 面试平台，支持简历智能分析、模拟面试、语音面试和知识库 RAG。
uber / AutoDispose
Automatic binding+disposal of RxJava streams.
alldatacenter / alldata
🔥🔥 AllData可定义数据中台，以数据平台为底座，以数据中台为桥梁，以机器学习平台为工厂，以大模型应用为上游产品，提供全链路数字化解决方案。产品正式演示体验、社群咨询、商务采购：https://docs.qq.com/doc/DVHlkSEtvVXVCdEFo
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
reactor / reactor-netty
TCP/HTTP/UDP/QUIC client/server with Reactor over Netty
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
amaembo / streamex
Enhancing Java Stream API
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:
jOOQ / jOOL
jOOλ - The Missing Parts in Java 8 jOOλ improves the JDK libraries in areas where the Expert Group's focus was elsewhere. It adds tuple support, function support, and a lot of additional functionality around sequential Streams. The JDK 8's main efforts (default methods, lambdas, and the Stream API) were focused around maintaining backwards compatibility and implementing a functional API for parallelism.
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
hantsy / spring-reactive-sample
Spring Reactive playground
hivemq / hivemq-mqtt-client
HiveMQ MQTT Client is an MQTT 5.0 and MQTT 3.1.1 compatible and feature-rich high-performance Java client library with different API flavours and backpressure support
pgjdbc / r2dbc-postgresql
Postgresql R2DBC Driver
spring-cloud / spring-cloud-stream
Framework for building Event-Driven Microservices
apple / servicetalk
A networking framework that evolves with your application
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.
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.
apache / datasketches-java
A software library of stochastic streaming algorithms, a.k.a. sketches.
smallrye / smallrye-mutiny
An Intuitive Event-Driven Reactive Programming Library for Java
Widdit / now-playing-service
一款全能的「正在播放」歌曲展示工具。支持检测 20+ 款音乐软件的歌曲信息，内置精美歌曲组件、歌词组件、播放器，提供 API 接口。适配 OBS 等直播软件以及日常桌面使用。
LegacyLands / legacy-lands-library
Enterprise-grade modular framework for Minecraft server development with multi-tier caching, Redis Streams, resilient data processing, and modern Java concurrency. Built on Fairy Framework for production-scale plugin development.
apache / geaflow
Apache GeaFlow: A Streaming Graph Computing Engine.
apache / streampipes
Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams.