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.
Upserts And Incremental Processing on Big Data
Project SnappyData - memory optimized analytics database, based on Apache Spark™ and Apache Geode™. Stream, Transact, Analyze, Predict in one cluster
GeoMesa is a suite of tools for working with big geo-spatial data in a distributed fashion.
Mirror of Apache Samza
Lightweight real-time big data streaming engine over Akka
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.
A library that provides an in-memory Kafka instance to run your tests against.
Scala helper modules for operating the Apache Kafka client library (0.9.x - 1.0.x)
Large-scale event processing with Akka Persistence and Apache Spark
A replicated Akka Persistence journal backed by Apache Kafka
Thin Scala wrapper around Kafka Streams Java API
reactive kafka client
Scala DSL for Unit-Testing Processing Topologies in Kafka Streams
Functional Kafka Streams for Scala
Low level integration of Spark and Kafka