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 /reactive-streams-jvm

Java4.9K530

Reactive Streams Specification for the JVM

amaembo /streamex

Java2.3K260

Enhancing Java Stream API

java
java8
collections
streams-api

jOOQ /jOOL

Java2.1K175

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.

AOL-archive /cyclops

Java1.3K134

An advanced, but easy to use, platform for writing functional applications in Java 8.

functional-programming
reactive-streams
monoid
streams

hivemq /hivemq-mqtt-client

Java1.1K187

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

mqtt
mqtt-client
mqtt-protocol
reactive-streams

apple /servicetalk

Java1K237

A networking framework that evolves with your application

java
reactive
reactive-streams
microservices

authorjapps /zerocode

Java1K455

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.

soap
assertions
java
api

apache /streampipes

Java756249

Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams.

pivovarit /parallel-collectors

Java68365

Parallel Collectors is a toolkit easing parallel collection processing in Java using Stream API.

parallelism
parallel-streams
stream-api
hacktoberfest

scalecube /scalecube-services

Java639112

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-enterprises /littlehorse

Java40139

LittleHorse Server: Business-as-Code Platform for Microservices, Workflows, and Agents

awslabs /amazon-kinesis-scaling-utils

Java33584

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.