Model import deployment framework for retraining models (pytorch, tensorflow,keras) deploying in JVM Micro service environments, mobile devices, iot, and Apache Spark
Reactive Microservices for the JVM
Fast, Scientific and Numerical Computing for the JVM (NDArrays)
Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
Project SnappyData - memory optimized analytics database, based on Apache Spark™ and Apache Geode™. Stream, Transact, Analyze, Predict in one cluster
Upserts And Incremental Processing on Big Data
Lightweight real-time big data streaming engine over Akka
Mirror of Apache Samza
Storehaus is a library that makes it easy to work with asynchronous key value stores
Tranquility helps you send real-time event streams to Druid and handles partitioning, replication, service discovery, and schema rollover, seamlessly and without downtime.
Manage your Kafka ACL at scale
Large-scale event processing with Akka Persistence and Apache Spark
Scala helper modules for operating the Apache Kafka client library (0.9.x - 1.0.x)
A library that provides an in-memory Kafka instance to run your tests against.
Greyhound - Rich Kafka client library
A replicated Akka Persistence journal backed by Apache Kafka
Scala DSL for Unit-Testing Processing Topologies in Kafka Streams
Process authoring tool for Apache Flink