RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.
Repository Index
47,133 repositories indexed
1–24 of 25 · Most stars
Modern Java - A Guide to Java 8
Open-Source Web UI for Apache Kafka Management
Efficient reliable UDP unicast, UDP multicast, and IPC message transport
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.
Reactive Streams Specification for the JVM
Enhancing Java Stream API
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.
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
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.
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
LittleHorse Server: Business-as-Code Platform for Microservices, Workflows, and Agents
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.
The Amazon DynamoDB Streams Adapter implements the Amazon Kinesis interface so that your application can use KCL to consume and process data from a DynamoDB stream.
A collection of classes to give a fluent builder for Streams (Lazy Groovy Generators)
Apache JMeter plugin for load testing HLS and MPEG-DASH video streams. Simulates adaptive bitrate playback, manifest/segment downloads, and live or VOD streaming.
No description provided by the repository host.
Gatherers library for Java Stream API
Develop streaming applications for IBM Streams in Python, Java & Scala.
Distributed, Scalable, Fault-Tolerant, Minimalistic Workflow Engine - No DAGs, No YAML, No Cumbersome Diagrams, Just Code