MobX is a battle tested, simple and scalable state management library transparently applying functional reactive programming (TFRP). The Mobx design principle is very simple: Anything that can be derived from the application state, should be derived. Automatically. This includes the UI, data serialization, server communication, etc.

MobX - Simple, scalable state management.

Kafka UI is a UI for Apache Kafka to monitor and manage Apache Kafka clusters. It is a simple tool that makes your data flows observable, helps find and troubleshoot issues faster and deliver optimal performance. Its lightweight dashboard makes it easy to track key metrics of your Kafka clusters - Brokers, Topics, Partitions, Production, and Consumption. 
Its features include: 
<ul>
<li>Multi-Cluster Management — monitor and manage all your clusters in one place</li>
<li>Performance Monitoring with Metrics Dashboard — track key Kafka metrics with a lightweight dashboard</li>
<li>View Kafka Brokers — view topic and partition assignments, controller status</li>
<li>View Kafka Topics — view partition count, replication status, and custom configuration</li>
<li>View Consumer Groups — view per-partition parked offsets, combined and per-partition lag</li>
<li>Browse Messages — browse messages with JSON, plain text, and Avro encoding</li>
<li>Dynamic Topic Configuration — create and configure new topics with dynamic configuration</li>
<li>Configurable Authentification — secure your installation with optional Github/Gitlab/Google OAuth 2.0</li>
</ul>

Kafka UI is a UI for Apache Kafka to monitor and manage Apache Kafka clusters. It is a simple tool that makes your data flows observable, helps find and troubleshoot issues faster and deliver optimal performance. Its lightweight dashboard makes it easy to track key metrics of your Kafka clusters - Brokers, Topics, Partitions, Production, and Consumption.

Kafka UI - Open-Source Web UI for Apache Kafka Management

A lightweight wrapper around SQLiteOpenHelper and ContentResolver which introduces reactive stream semantics to queries. SQL Brite's only responsibility is to be a mechanism for coordinating and composing the notification of updates to tables such that you can update queries as soon as data changes. This library is not an ORM. It is not a type-safe query mechanism. It won't serialize the same POJOs you use for Gson. It's not going to perform database migrations for you.

Sqlbrite - A lightweight wrapper around SQLiteOpenHelper which introduces reactive stream semantics to SQL operations

pump.io is a stream server that does most of what people really want from a social network. You post anything and my followers see it. It is an alternative to twitter. You can post almost anything that can be represented with activity streams -- short or long text, bookmarks, images, video, audio, events, geo checkins. You can follow friends, create lists of people, and so on.

pump.io - Social server with an ActivityStreams API

Hazelcast Jet is a distributed computing platform built for high-performance stream processing and fast batch processing. It embeds Hazelcast In-Memory Data Grid (IMDG) to provide a lightweight, simple-to-deploy package that includes scalable in-memory storage. Hazelcast Jet performs parallel execution to enable data-intensive applications to operate in near real-time.
 
Hazelcast Jet gives you all the infrastructure you need to build a distributed data processing pipeline within one 10Mb Java JAR: processing, storage and clustering. Hazelcast Jet comes with in-memory operational storage that’s available out-of-the box. This storage is partitioned, distributed and replicated across the Hazelcast Jet cluster for capacity and resiliency. It can be used as an input data buffer, to publish the results of a Hazelcast Jet computation, to connect multiple Hazelcast Jet jobs or as a lookup cache for data enrichment.

Hazelcast Jet is a distributed computing platform built for high-performance stream processing and fast batch processing. It embeds Hazelcast In-Memory Data Grid (IMDG) to provide a lightweight, simple-to-deploy package that includes scalable in-memory storage. Hazelcast Jet performs parallel execution to enable data-intensive applications to operate in near real-time.

Hazelcast Jet - A general purpose distributed data processing engine, built on top of Hazelcast.

Vavr is an object-functional language extension to Java 8, which aims to reduce the lines of code and increase code quality. It provides persistent collections, functional abstractions for error handling, concurrent programming, pattern matching and much more.
 
Vavr fuses the power of object-oriented programming with the elegance and robustness of functional programming. The most interesting part is a feature-rich, persistent collection library that smoothly integrates with Java's standard collections.

Vavr is an object-functional language extension to Java 8, which aims to reduce the lines of code and increase code quality. It provides persistent collections, functional abstractions for error handling, concurrent programming, pattern matching and much more.

Vavr - Object-functional language extension to Java

ZIO is a zero-dependency Scala library for asynchronous and concurrent programming. It is powered by highly-scalable, non-blocking fibers that never waste or leak resources, ZIO lets you build scalable, resilient, and reactive applications that meet the needs of your business.
 
<ul>
<li>High-performance. Build scalable applications with 100x the performance of Scala's <code>Future</code>.</li>
<li>Type-safe. Use the full power of the Scala compiler to catch bugs at compile time.</li>
<li>Concurrent. Easily build concurrent apps without deadlocks, race conditions, or complexity.</li>
<li>Asynchronous. Write sequential code that looks the same whether it's asynchronous or synchronous.</li>
<li>Resource-safe. Build apps that never leak resources (including threads!), even when they fail.</li>
<li>Testable. Inject test services into your app for fast, deterministic, and type-safe testing.</li>
<li>Resilient. Build apps that never lose errors, and which respond to failure locally and flexibly.</li>
<li>Functional. Rapidly compose solutions to complex problems from simple building blocks.</li>
</ul>

ZIO is a zero-dependency Scala library for asynchronous and concurrent programming. It is powered by highly-scalable, non-blocking fibers that never waste or leak resources, ZIO lets you build scalable, resilient, and reactive applications that meet the needs of your business.

Zio - A type-safe, composable library for async and concurrent programming in Scala 

TymeacRSE is a Recursive Streams push engine for managing the publication and distribution of items to subscribers. An efficient push engine allowing (Reactive Stream) Publishers to generate asynchronous streams for routing to Subscribers. It provides an efficient multitasking service that allows many resource-intensive applications to coexist in a single microservice.

TymeacRSE - Java Reactive Streams Push Engine

Monix is a high-performance Scala / Scala.js library for composing asynchronous and event-based programs, exposing high-level types, such as observable sequences that are exposed as asynchronous streams, expanding on the observer pattern, strongly inspired by ReactiveX and by Scalaz, but designed from the ground up for back-pressure and made to cleanly interact with Scala’s standard library, compatible out-of-the-box with the Reactive Streams protocol.

Monix - Asynchronous Programming for Scala and Scala.js

Mutiny places events at the core of its design. With Mutiny, you observe events, react to them, and create elegant and readable processing pipelines. Mutiny is the perfect companion to tame the asynchronous nature of applications with non-blocking I/O. Declaratively compose operations, transform data, enforce progress, recover from failures and more. 
 
 Mutiny can be used in any asynchronous application such as event-driven microservices, message-based applications, network utilities, data stream processing, and reactive applications.

Mutiny places events at the core of its design. With Mutiny, you observe events, react to them, and create elegant and readable processing pipelines. Mutiny is the perfect companion to tame the asynchronous nature of applications with non-blocking I/O. Declaratively compose operations, transform data, enforce progress, recover from failures and more. 

Mutiny - An Intuitive Event-Driven Reactive Programming Library for Java

Essentials4j is a minimalistic library consisting of a thin layer of abstraction over Java 8 streams for easy manipulation of collections and a simple factory utils for elegant construction of collections.


essentials4j - Essentials for Java 8+

A small collection of Stream utilities for Java 8. Protonpack provides takeWhile, takeUntil, skipWhile, skipUntil, zip, zipWithIndex, unfold, MapStream, aggregate, Streamable, unique collector.

Protonpack - Stream utilities for Java 8

Discover open source projects across all platforms

Projects