47,133 repositories indexed
25–48 of 71 · Most stars
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.
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.
Speedment is a Stream ORM Java Toolkit and Runtime
EventMesh is a new generation serverless event middleware for building distributed event-driven applications.
🦎 A lightweight, streaming-native, multi-protocol gateway for AI, APIs, and real-time data. Route LLM requests across providers, govern MCP tools, and connect Kafka, MQTT, and HTTP through one high-performance engine with shared security and observability.
Stream Processing and Complex Event Processing Engine
Apache InLong - a one-stop, full-scenario integration framework for massive data
An advanced, but easy to use, platform for writing functional applications in Java 8.
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
Framework for building Event-Driven Microservices
A networking framework that evolves with your application
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.
An extensible distributed system for reliable nearline data streaming at scale
A software library of stochastic streaming algorithms, a.k.a. sketches.
Esper Complex Event Processing, Streaming SQL and Event Series Analysis
Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams.
Parallel Collectors is a toolkit easing parallel collection processing in Java using Stream API.
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
Stream utilities for Java 8
An extensible Java framework for building event-driven applications that break up XML and non-XML data into chunks for data integration
LittleHorse Server: Business-as-Code Platform for Microservices, Workflows, and Agents
Client-side response routing for Spring
The Kinesis Scaling Utility is designed to give you the ability to scale Amazon Kinesis Streams in the same way that you scale EC2 Auto Scaling groups – up or down by a count or as a percentage of the total fleet. You can also simply scale to an exact number of Shards. There is no requirement for you to manage the allocation of the keyspace to Shards when using this API, as it is done automatically.
A streaming JsonPath processor in Java